問題タブ [azure-servicebus-topics]

Azure Service Bus トピックにサブスクライブしており、Python クライアントから送信されたオブジェクトを取得しようとしています。しかし、私の受信側では、次のようなものしか得られません。

Pythonと.NETで受信してみました。ここに私が試したもののダミーコードがあります:

C# でダミー コードを受け取る:

送信者から送信されたユーザー オブジェクト (user_id と名前) を取得するにはどうすればよいですか?

Azure Web サイトでホストされているジョブがあり、ジョブはトピック サブスクリプションからエントリを読み取ります。Web サイトをホストするインスタンスが 1 つしかない場合、すべてが正常に機能します。複数のインスタンスにスケールアウトすると、メッセージがインスタンスの数だけ処理されることがわかります。各インスタンスは同じサブスクリプションを指します。私たちが読んだことから、アイテムが読み取られると、他のプロセスでは使用できなくなります。重複した処理は同じインスタンス内で発生しています。つまり、2 つのインスタンスがある場合、アイテムはインスタンスの 1 つで 2 回処理され、分割されません。

私たちが物事を行う方法で何が間違っている可能性がありますか? これは、キューへの接続を構成する方法です。サブスクリプションが存在しない場合は、作成されます。

トピック アイテムを処理するコードの例:

このメソッドは Function 静的クラス内にあり、Azure Web Job SDK を使用しています。

Azure Web サイトが複数のインスタンスにスケーリングされる場合は常に、すべてのインスタンスが同じ構成を共有します。

マルチ インスタンス アプリケーションがあり、サービス バス イベント ハブを使用していくつかのメッセージを入れ、それを他のすべてのインスタンスにブロードキャストしています。すべてのインスタンスにメッセージを送信するための条件は、すべてのインスタンスが個別のコンシューマー グループにある必要があることです。それ以外の場合、インスタンスはメッセージを取得して削除するため、他のインスタンスはメッセージを取得できません。したがって、私の解決策は、最初にすべてのインスタンスが独自のコンシューマー グループを作成し、次にイベント ハブをリッスンすることでしたが、ここでの問題は、インスタンスのクラッシュにより、しばらくすると多くの消費者グループが使用されなくなります。私の質問は、テーマを削除するために使用されていないすべての消費者グループを検出して取得することは可能ですか?

PS：トピック/サブスクリプションも試しましたが、うまく機能しますが、上記のコンシューマーグループをサブスクリプションで置き換えるだけで同じ問題があります:)。

Azure Service Bus のトピックとサブスクリプションを監視するユーティリティを作成しています。

名前、キューに入れられたメッセージ数、配信不能メッセージ数などのトピックの詳細を取得できますが、処理されたメッセージの数を取得したいと考えています。

私が使用しているコードは次のとおりです。

GetSubscription処理されたメッセージの数を取得するためのプロパティが含まれていないようです。

誰もこれをやろうとしたことがありますか？