【发布时间】:2019-11-02 01:00:48
【问题描述】:
我正在使用 python 语言通过 Azure 总线服务队列发送和接收消息。
使用以下代码从队列中删除消息时,我收到“提供的锁无效。锁已过期,或者消息已从队列中删除”。
sbs.delete_queue_message('taskqueue',5,'ef4e2189-bfef-42ac-ba09-7fd20287f6a9') sbs.delete_queue_message('taskqueue','SequenceNumber','LockToken')
from azure.servicebus.control_client import ServiceBusService, Message, Topic, Rule, DEFAULT_RULE_NAME
key_name = '###############' # SharedAccessKeyName from Azure portal
key_value = '####################' # SharedAccessKey from Azure portal
service_namespace = '###########'
sbs = ServiceBusService(service_namespace,shared_access_key_name=key_name,shared_access_key_value=key_value)
msg = sbs.receive_queue_message('taskqueue')
sbs.delete_queue_message('taskqueue',5,'ef4e2189-bfef-42ac-ba09-7fd20287f6a9')
【问题讨论】:
-
您从哪里获得此锁定令牌 (
ef4e2189-bfef-42ac-ba09-7fd20287f6a9) 值? -
使用 msg.broker_properties['LockToken'])
标签: python azure message-queue azureservicebus