airflow.providers.microsoft.azure.queues.asb¶

Classes¶

AzureServiceBusMessageQueueProvider

Configuration for Azure Service Bus integration with common-messaging.

Module Contents¶

class airflow.providers.microsoft.azure.queues.asb.AzureServiceBusMessageQueueProvider[source]¶

Bases: airflow.providers.common.messaging.providers.base_provider.BaseMessageQueueProvider

Configuration for Azure Service Bus integration with common-messaging.

[START azure_servicebus_message_queue_provider_description]

It uses azure+servicebus as the scheme for identifying the provider.
For parameter definitions, take a look at AzureServiceBusQueueTrigger.

from airflow.providers.common.messaging.triggers.msg_queue import MessageQueueTrigger
from airflow.sdk import Asset, AssetWatcher

trigger = MessageQueueTrigger(
    scheme="azure+servicebus",
    # AzureServiceBusQueueTrigger parameters
    queues=["my-queue"],
    azure_service_bus_conn_id="azure_service_bus_default",
    poll_interval=60,
)

asset = Asset(
    "asb_queue_asset",
    watchers=[AssetWatcher(name="asb_watcher", trigger=trigger)],
)

[END azure_servicebus_message_queue_provider_description]

scheme = 'azure+servicebus'[source]¶

trigger_class()[source]¶

Trigger class to use when queue_matches returns True.