Azure 服务总线操作符¶
Azure 服务总线是一个完全托管的企业消息代理，具有消息队列和发布-订阅主题（在命名空间中）。服务总线用于将应用程序和服务彼此解耦。服务总线对实体（如命名空间、队列和主题）执行操作。
- 服务总线 REST API 提供了用于处理以下资源的操作
Azure 资源管理器
服务总线服务
Azure 服务总线队列操作符¶
Azure 服务总线操作符有助于与基于 Azure 总线队列的操作进行交互，例如在队列中创建、删除、发送和接收消息。
创建 Azure 服务总线队列¶
要使用特定参数创建 Azure 服务总线队列，可以使用 AzureServiceBusCreateQueueOperator。
以下是使用此操作符执行 Azure 服务总线创建队列的示例。
create_service_bus_queue = AzureServiceBusCreateQueueOperator(
task_id="create_service_bus_queue",
queue_name=QUEUE_NAME,
)
向 Azure 服务总线队列发送消息¶
要向 Azure 服务总线队列发送消息或消息列表或批量消息。你可以使用 AzureServiceBusSendMessageOperator。
以下是使用此操作符执行 Azure 服务总线向队列发送消息的示例。
send_message_to_service_bus_queue = AzureServiceBusSendMessageOperator(
task_id="send_message_to_service_bus_queue",
message=MESSAGE,
queue_name=QUEUE_NAME,
batch=False,
)
接收 Azure 服务总线队列消息¶
要接收队列中的消息或消息列表或批量消息，可以使用 AzureServiceBusReceiveMessageOperator。
以下是使用此操作符执行 Azure 服务总线创建队列的示例。
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 服务总线队列¶
要删除 Azure 服务总线队列，可以使用 AzureServiceBusDeleteQueueOperator。
以下是使用此操作符执行 Azure 服务总线删除队列的示例。
delete_service_bus_queue = AzureServiceBusDeleteQueueOperator(
task_id="delete_service_bus_queue", queue_name=QUEUE_NAME, trigger_rule="all_done"
)
Azure 服务总线主题操作符¶
基于 Azure 服务总线主题的操作符有助于与服务总线命名空间中的主题进行交互，并有助于对主题进行创建、删除操作。
创建 Azure 服务总线主题¶
要使用特定参数创建 Azure 服务总线主题，可以使用 AzureServiceBusTopicCreateOperator。
以下是使用此操作符执行 Azure 服务总线创建主题的示例。
create_service_bus_topic = AzureServiceBusTopicCreateOperator(
task_id="create_service_bus_topic", topic_name=TOPIC_NAME
)
删除 Azure 服务总线主题¶
要删除 Azure 服务总线主题，可以使用 AzureServiceBusTopicDeleteOperator。
以下是使用此操作符执行 Azure 服务总线删除主题的示例。
delete_asb_topic = AzureServiceBusTopicDeleteOperator(
task_id="delete_asb_topic",
topic_name=TOPIC_NAME,
)
Azure 服务总线订阅操作符¶
基于 Azure 服务总线订阅的操作符有助于与服务总线命名空间中的主题订阅进行交互，并有助于对主题下的订阅进行创建、删除操作。
创建 Azure 服务总线订阅¶
要使用特定参数创建 Azure 服务总线主题订阅，可以使用 AzureServiceBusSubscriptionCreateOperator。
以下是使用此操作符执行 Azure 服务总线创建订阅的示例。
create_service_bus_subscription = AzureServiceBusSubscriptionCreateOperator(
task_id="create_service_bus_subscription",
topic_name=TOPIC_NAME,
subscription_name=SUBSCRIPTION_NAME,
)
更新 Azure 服务总线订阅¶
要使用特定参数更新已创建的 Azure 服务总线主题订阅，可以使用 AzureServiceBusUpdateSubscriptionOperator。
以下是使用此操作符执行 Azure 服务总线更新订阅的示例。
update_service_bus_subscription = AzureServiceBusUpdateSubscriptionOperator(
task_id="update_service_bus_subscription",
topic_name=TOPIC_NAME,
subscription_name=SUBSCRIPTION_NAME,
max_delivery_count=5,
)
接收 Azure 服务总线订阅消息¶
要从特定主题下的服务总线订阅接收批量消息，可以使用 ASBReceiveSubscriptionMessageOperator。
以下是使用此操作符执行 Azure 服务总线接收订阅消息的示例。
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 服务总线订阅¶
要删除 Azure 服务总线主题订阅，可以使用 AzureServiceBusSubscriptionDeleteOperator。
以下是使用此操作符执行 Azure 服务总线删除主题下的订阅的示例。
delete_service_bus_subscription = AzureServiceBusSubscriptionDeleteOperator(
task_id="delete_service_bus_subscription",
topic_name=TOPIC_NAME,
subscription_name=SUBSCRIPTION_NAME,
trigger_rule="all_done",
)