tests.system.microsoft.azure.example_event_schedule_asb

Example Airflow DAG that demonstrates using Azure Service Bus with MessageQueueTrigger and Asset Watchers for event-driven workflows.

This example shows how to create a DAG that triggers when messages arrive in an Azure Service Bus queue using Asset Watchers.

Prerequisites

Before running this example, ensure you have:

  1. An Azure Service Bus namespace

  2. A queue created in the namespace (e.g., my-queue)

  3. An Airflow connection configured with ID azure_service_bus_default

How to test

  1. Ensure the Azure Service Bus queue exists (see Prerequisites above)

  2. Send a message to the queue to trigger the DAG

  3. The DAG will be triggered automatically when the message arrives

Attributes

trigger

asset

process_message_task

test_run

Module Contents

tests.system.microsoft.azure.example_event_schedule_asb.trigger[source]
tests.system.microsoft.azure.example_event_schedule_asb.asset[source]
tests.system.microsoft.azure.example_event_schedule_asb.process_message_task[source]
tests.system.microsoft.azure.example_event_schedule_asb.test_run[source]

Was this entry helpful?