2016-05-31 15 views
0

Я уже отправляю пакетные сообщения с использованием C# libs. Я хочу сделать то же самое, используя python, как это сделать? На самом деле я могу отправлять отдельные сообщения, но пакетная отправка увеличит мою пропускную способность. Это код:Как отправить несколько сообщений в eventhub с помощью 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-строка в кодировке, которая содержит несколько сообщений.»

Link to the manual

ответ

2

Попробуйте заменить содержание событий с форматом, как это,

[{"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 для некоторая информация.

 Смежные вопросы

  • Нет связанных вопросов^_^