Azure Service Bus Operators¶

Azure Service Bus 是一個完全託管的企業訊息中轉站，包含訊息佇列和釋出/訂閱主題（在名稱空間中）。Service Bus 用於解耦應用程式和服務。Service Bus 在實體（如名稱空間、佇列和主題）上執行操作。

Service Bus REST API 提供了用於處理以下資源的操作

Azure Resource Manager
Service Bus 服務

Azure Service Bus 佇列 Operators¶

Azure Service Bus Operator 幫助與基於 Azure Service Bus 佇列的操作進行互動，例如建立、刪除、傳送和接收佇列中的訊息。

建立 Azure Service Bus 佇列¶

要使用特定引數建立 Azure Service Bus 佇列，可以使用 AzureServiceBusCreateQueueOperator。

下面是使用此 Operator 執行 Azure Service Bus 建立佇列操作的示例。

tests/system/microsoft/azure/example_azure_service_bus.py

create_service_bus_queue = AzureServiceBusCreateQueueOperator(
    task_id="create_service_bus_queue",
    queue_name=QUEUE_NAME,
)

向 Azure Service Bus 佇列傳送訊息¶

要向 Azure Service Bus 佇列傳送訊息、訊息列表或批次訊息。可以使用 AzureServiceBusSendMessageOperator。

下面是使用此 Operator 執行 Azure Service Bus 傳送訊息到佇列操作的示例。

tests/system/microsoft/azure/example_azure_service_bus.py

send_message_to_service_bus_queue = AzureServiceBusSendMessageOperator(
    task_id="send_message_to_service_bus_queue",
    message=MESSAGE,
    queue_name=QUEUE_NAME,
    batch=False,
)

從 Azure Service Bus 佇列接收訊息¶

要在佇列中接收訊息、訊息列表或批次訊息，可以使用 AzureServiceBusReceiveMessageOperator。

下面是使用此 Operator 執行 Azure Service Bus 建立佇列操作的示例。

tests/system/microsoft/azure/example_azure_service_bus.py

receive_message_service_bus_queue = AzureServiceBusReceiveMessageOperator(
    task_id="receive_message_service_bus_queue",
    queue_name=QUEUE_NAME,
    max_message_count=20,
    max_wait_time=5,
)

刪除 Azure Service Bus 佇列¶

要刪除 Azure Service Bus 佇列，可以使用 AzureServiceBusDeleteQueueOperator。

下面是使用此 Operator 執行 Azure Service Bus 刪除佇列操作的示例。

tests/system/microsoft/azure/example_azure_service_bus.py

delete_service_bus_queue = AzureServiceBusDeleteQueueOperator(
    task_id="delete_service_bus_queue", queue_name=QUEUE_NAME, trigger_rule="all_done"
)

Azure Service Bus 主題 Operators¶

基於 Azure Service Bus 主題的 Operator 幫助與 Service Bus 名稱空間中的主題進行互動，並幫助執行主題的建立、刪除操作。

建立 Azure Service Bus 主題¶

要使用特定引數建立 Azure Service Bus 主題，可以使用 AzureServiceBusTopicCreateOperator。

下面是使用此 Operator 執行 Azure Service Bus 建立主題操作的示例。

tests/system/microsoft/azure/example_azure_service_bus.py

create_service_bus_topic = AzureServiceBusTopicCreateOperator(
    task_id="create_service_bus_topic", topic_name=TOPIC_NAME
)

刪除 Azure Service Bus 主題¶

要刪除 Azure Service Bus 主題，可以使用 AzureServiceBusTopicDeleteOperator。

下面是使用此 Operator 執行 Azure Service Bus 刪除主題操作的示例。

tests/system/microsoft/azure/example_azure_service_bus.py

delete_asb_topic = AzureServiceBusTopicDeleteOperator(
    task_id="delete_asb_topic",
    topic_name=TOPIC_NAME,
)

Azure Service Bus 訂閱 Operators¶

基於 Azure Service Bus 訂閱的 Operator 幫助與 Service Bus 名稱空間中的主題訂閱進行互動，並幫助執行主題下訂閱的建立、刪除操作。

建立 Azure Service Bus 訂閱¶

要使用特定引數建立 Azure Service Bus 主題訂閱，可以使用 AzureServiceBusSubscriptionCreateOperator。

下面是使用此 Operator 執行 Azure Service Bus 建立訂閱操作的示例。

tests/system/microsoft/azure/example_azure_service_bus.py

create_service_bus_subscription = AzureServiceBusSubscriptionCreateOperator(
    task_id="create_service_bus_subscription",
    topic_name=TOPIC_NAME,
    subscription_name=SUBSCRIPTION_NAME,
)

更新 Azure Service Bus 訂閱¶

要使用特定引數更新已建立的 Azure Service Bus 主題訂閱，可以使用 AzureServiceBusUpdateSubscriptionOperator。

下面是使用此 Operator 執行 Azure Service Bus 更新訂閱操作的示例。

tests/system/microsoft/azure/example_azure_service_bus.py

update_service_bus_subscription = AzureServiceBusUpdateSubscriptionOperator(
    task_id="update_service_bus_subscription",
    topic_name=TOPIC_NAME,
    subscription_name=SUBSCRIPTION_NAME,
    max_delivery_count=5,
)

接收 Azure Service Bus 訂閱訊息¶

要從特定主題下的 Service Bus 訂閱接收批次訊息，可以使用 ASBReceiveSubscriptionMessageOperator。

下面是使用此 Operator 執行 Azure Service Bus 接收訂閱訊息操作的示例。

tests/system/microsoft/azure/example_azure_service_bus.py

receive_message_service_bus_subscription = ASBReceiveSubscriptionMessageOperator(
    task_id="receive_message_service_bus_subscription",
    topic_name=TOPIC_NAME,
    subscription_name=SUBSCRIPTION_NAME,
    max_message_count=10,
)

刪除 Azure Service Bus 訂閱¶

要刪除 Azure Service Bus 主題訂閱，可以使用 AzureServiceBusSubscriptionDeleteOperator。

下面是使用此 Operator 執行 Azure Service Bus 刪除主題下訂閱操作的示例。

tests/system/microsoft/azure/example_azure_service_bus.py

delete_service_bus_subscription = AzureServiceBusSubscriptionDeleteOperator(
    task_id="delete_service_bus_subscription",
    topic_name=TOPIC_NAME,
    subscription_name=SUBSCRIPTION_NAME,
    trigger_rule="all_done",
)

參考¶

更多資訊，請參考 Microsoft 文件

Azure Service Bus 文件