Pythonでamqpを使ってAzureイベントハブにメッセージを送信するには

Question

誰かがamqpを使ってPythonでAzureイベントハブにメッセージを送信する方法を知っていますか？パーティションキー（パーティションIDではなく）でメッセージを送信する必要があります。どうもありがとう。

Answer 1

公文書Partitioned queues and topicsの​​セクションによれば、以下のように、メッセージのPartitionKeyプロパティを設定してパーティションキーでメッセージを送信することができます。

のPartitionKey：メッセージがBrokeredMessage.PartitionKey財産ではなくBrokeredMessage.SessionIdプロパティセットを持っている場合、Service Busは、パーティション・キーとしてのPartitionKeyプロパティを使用しています。メッセージにSessionIdとPartitionKeyの両方のプロパティが設定されている場合は、両方のプロパティが同一でなければなりません。 PartitionKeyプロパティがSessionIdプロパティと異なる値に設定されている場合、Service Busは無効な操作例外を返します。送信者が非セッション対応トランザクションメッセージを送信する場合は、PartitionKeyプロパティを使用する必要があります。パーティションキーは、トランザクション内で送信されるすべてのメッセージが同じメッセージブローカによって処理されることを保証します。

以下の手順でPythonを使用します。

1. pip install python-qpid-protonでAMQPのPython Qpid Protonパッケージをインストールします。

2. 参考資料としてのサンプルコードです。

   from proton import Messenger, Message 
   
   messenger = Messenger() 
   
   message = Message() 
   message.address = "amqps://<shared_access_policy_name>:<shared_access_policy_key>@<your-servicebus-namespace>.servicebus.windows.net/<your-eventhub-name>" 
   
   message.properties = { 
       "PartitonKey" : "<a partitonKey you want>", 
   } 
   
   message.body = u"This is a text string" 
   messenger.put(message) 
   messenger.send() 
   

proton.Messageクラスリファレンスhereを参照してください。

希望します。