ASBReceiveSubscriptionMessageOperator
Microsoft AzureReceive a Batch messages from a Service Bus Subscription under specific Topic.
Access Instructions
Install the Microsoft Azure provider package into your Airflow environment.
Import the module into your DAG file and instantiate it with your desired params.
Parameters
subscription_nameRequiredThe subscription name that will own the rule in topic
topic_nameRequiredThe topic that will own the subscription rule.
max_message_countMaximum number of messages in the batch. Actual number returned will depend on prefetch_count and incoming stream rate. Setting to None will fully depend on the prefetch config. The default value is 1.
max_wait_timeMaximum time to wait in seconds for the first message to arrive. If no messages arrive, and no timeout is specified, this call will not return until the connection is closed. If specified, an no messages arrive within the timeout period, an empty list will be returned.
azure_service_bus_conn_idReference to the Azure Service Bus connection.
Documentation
Receive a Batch messages from a Service Bus Subscription under specific Topic.
See also
For more information on how to use this operator, take a look at the guide: Receive Azure Service Bus Subscription Message