2016-05-31 19 views
0

私はすでにC#libsを使用してバッチメッセージを送信しています。 私はPythonを使って同じことをしたい、それを行う方法? 実際には1つのメッセージを送信できますが、バッチ送信ではスループットが向上します。 は、これはコードです:pythonを使用して複数のメッセージをeventhubに送信する方法

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を参照してください。いくつかの情報。

関連する問題