我已经使用 C# 库发送批量消息。 我想用 python 做同样的事情,该怎么做? 实际上我可以发送单条消息,但批量发送会增加我的吞吐量。 这是代码:
from azure.servicebus import ServiceBusService
key_name = 'RootManageSharedAccessKey' # SharedAccessKeyName from Azure portal
key_value = '' # SharedAccessKey from Azure portal
sbs = ServiceBusService(service_namespace,
shared_access_key_name=key_name,
shared_access_key_value=key_value)
sbs.send_event('myhub', '{ "DeviceId":"dev-01", "Temperature":"37.0" }')
我认为这是可能的,因为手册上写着:
“事件内容是事件消息或包含多条消息的 JSON 编码字符串。”
最佳答案
尝试将事件内容替换为这样的格式,
[{"Body":"Message1"},{"Body":"Message2"},{"Body":"Message3"}]
所以完整的代码是这样的,
from azure.servicebus import ServiceBusService
key_name = 'RootManageSharedAccessKey' # SharedAccessKeyName from Azure portal
key_value = 'hdckR8xd*********************u5a84RoZSQHE=' # SharedAccessKey from Azure portal
service_namespace = 'myservice-ns' # service bus namespace
sbs = ServiceBusService(service_namespace,
shared_access_key_name=key_name,
shared_access_key_value=key_value)
sbs.create_event_hub('myhub')
sbs.send_event('myhub', '[{"name":"derek", "gender":"male"},{ "DeviceId":"dev-01", "Temperature":"37.0" }]')
引用Event Hubs (classic) REST获取一些信息。
关于python - 如何使用python向eventhub发送多条消息,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/37551807/