ASBReceiveSubscriptionMessageOperator
Created by
Airflow Community
Version
Receive a Batch messages from a Service Bus Subscription under specific Topic.
Parameters
topic_name
strREQUIRED
topic_name
strREQUIREDThe topic that will own the subscription rule.
subscription_name
strREQUIRED
subscription_name
strREQUIREDThe subscription name that will own the rule in topic
max_message_count
int | None
max_message_count
int | NoneMaximum 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_time
float | None
max_wait_time
float | NoneMaximum 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_id
str
azure_service_bus_conn_id
strReference 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
