Implement synchronous Azure Service Bus Queue Operators

[bharanidharan14]

Implement synchronous Azure service bus queue operators

• CreateQueueOperator

• UpdateQueueOperator

• DeleteQueueOperator

• GetQueueRuntimePropertiesOperator

• SendQueueMessageOperator(single message, list of message, batch message)

• ReceiveQueueMessageOperator

• Unit Tests coverage in the PR (80% Code Coverage -- We will need to add CodeCov separately to measure code cov) with all of them passing

• Example DAG using the sync Operator that can be used to run Integration tests that are parametrized via Environment variables. Example - https://github.com/apache/airflow/blob/8a03a505e1df0f9de276038c5509135ac569a667/airflow/providers/google/cloud/example_dags/example_bigquery_to_gcs.py#L33-L35

• Add proper docstrings for each of the methods and functions including Example DAG on how it should be used (populate

• Exception Handling in case of errors

Notion page link: https://www.notion.so/astronomerio/Azure-Service-Bus-130e1721f68f4526b20d081798dd66da

[bharanidharan14]

Created operator for the following

• CreateQueueOperator
• DeleteQueue
• SendMessage Queue Operator

currently working on Integration testing and test case

[bharanidharan14]

Testing the operator with example DAG, got stuck with some dependencies, resolved it and able to run the example DAG setting up the connection withe azure details, and writing test case

[bharanidharan14]

Implement new connection for Azure service bus, with connection details I can create queue, delete queue with operators

[bharanidharan14]

Pushed the code to repo branch azure-servicebus-queue-operators

[bharanidharan14]

apache/airflow#23717

[bharanidharan14]

• Moved the Azure service bus admin client hook and message hook as separate file
• Added params to create queue operators
• Improved the exception handling

[phanikumv]

ETA 24-May for development to complete

[bharanidharan14]

PR link : apache/airflow#24038

[bharanidharan14]

Addressed PR review comments and updated the PR

[bharanidharan14]

Addressed PR review comments

[phanikumv]

Awaiting implementation of review comment, can we close them quickly?