問題タブ [azure-eventhub]

「EventHubReceiver」(Device2Cloud) でデバイスからメッセージを受信しようとしています。各デバイスには、独自の単一の受信機が必要です。

すべてのデバイスに対して (パーティションごとに) 1 つの EventHubReceiver を作成しても問題ありません。

クライアントからメッセージを受信したい場合は、次の手順を実行します。

これで問題なく動作しますが、すべての「デバイス」からのすべてのメッセージがこの 1 つの「EventHubReceiver」に到着します。単一のデバイスからのみメッセージを受信する複数のレシーバーが必要です。
次のコードラインを変更しようとしました:

に

しかし、それはうまくいきません。次のエラーが表示されます。

したがって、問題は、デバイスごとに単一'devices/secondDevice/messages/events/$management'
の EventHubReceiver'devices/secondDevice/messages/events/'
を作成することができないのか、それともコードまたは思考にエラーがあるのか​​ 、わからないということです。

このRedDogツールを使用して SAS 署名を生成し、 Event Hub API refsを使用して Event Hub にメッセージを正常に送信しました。エンドポイントから 201 Created 応答を受け取ったので、成功したことがわかります。

この小さな成功は、私が答えを見つけることができなかった質問をもたらしました:

Azure ポータルにアクセスしましたが、作成したメッセージがどこにも表示されませんでした。さらに読んでみると、ストレージ アカウントを作成する必要があることがわかりました。ストレージ アカウントの資格情報などを必要とする C# の例 (EventProcessorHost) をいくつか見つけました。

質問は、データを永続化するために使用できる API はありますか? C# ツールを使用したくありません。

私のアプローチが間違っている場合は修正してください。しかし、私の目的は、テレメトリを EventHub に投稿し、データを永続化し、その上でいくつかの分析操作を実行できるようにすることです。テレメトリ データは、Azure で表示できるはずです。

サービス バス バックプレーンで SignalR を使用しています。Web サーバーではないものからメッセージを開始しようとしています。(イベント ハブ プロセッサ)

次のコードは、C# コマンド ライン アプリで正常に動作します。

しかし、イベント プロセッサ コードに追加すると、黙ってデータを送信しません。私の質問は、これをイベント ハブ プロセッサで動作するように設定するにはどうすればよいかということです。

私は現在、メッセージをブロードキャストする Web サイトに Web 要求を送信することで、この問題を回避しています。

ありがとう。

さまざまな種類のイベントがあります。たとえば、一部のデータはテレメトリ データであり、一部はエラー情報などです。

イベントの種類ごとに 1 つずつ、複数の IEventProcessor 実装を作成することをお勧めします。そのため、実装ごとにイベントの処理方法が異なります。ファイルやデータベースへの書き込みと同様です。

イベントを特定の EventProcessor にルーティングする最良の方法は何ですか?

• EventProcessor に特定のパーティション キーを監視させる必要がありますか。
• consumergroupname を指定できるようにする EventProcessorHost のコンストラクターを使用する必要がありますか? その場合、EventHubClient を使用して特定のコンシューマー グループに送信するにはどうすればよいですか? そこに消費者グループを指定するオプションが表示されません。
• 上記のいずれも実行せず、特定のプロパティの受信イベントデータをチェックし、興味のないものを無視する必要がありますか?

partitionkey と consumergroup (存在する場合) の関係については、文書化が不十分であると言わざるを得ません。

オプション 2 を使用しましたが、これまでのところ、各 EventProcessor は、EventProcessorHost コンストラクターで指定されたものだけでなく、すべてのコンシューマー グループ名からメッセージを取得します。

C# Winforms プロジェクトで Azure Event Hubs を使用しています。

EventProcessorHost オブジェクトと EventReciever オブジェクトを作成して、イベント ハブからメッセージを取得して表示する作業を実行します。

メッセージ取得プロセスの一部には、フォームが開かれたときにイベント ハブに新しいコンシューマー グループを作成することが含まれます。(コンシューマ グループ名を新しい GUID にするだけです)。

この^すべてが機能します。

フォームが閉じられると、コンシューマー グループはイベント ハブから削除されます。これは、ポータルを通じてイベント ハブを表示することによって検証されます。

ただし、イベント ハブの作業を行うためにコンシューマー グループによって使用されるパーティション オブジェクトは、まだストレージ アカウントに存在します。

CloudBerry エクスプローラーを使用すると、次のように表示されます。

各 GUID はコンシューマー グループです。私の開発の最後の数か月でここには数百ありますが、イベント ハブには一度に 20 のアクティブなコンシューマー グループしか含めることができません。

各コンシューマー グループ フォルダー内には、そのコンシューマー グループが使用する 4 つのパーティションのそれぞれに関する情報を含む 4 つのファイルがあります。

これらを自動的にクリーンアップできるイベント ハブ オブジェクト (EventReceiver、EventProcessorHost など) の API 呼び出しはありますか? 調べましたが、何も見つかりませんでした。現在、Event Hubs に関するドキュメントは最小限です。

EventProcessorHost.PartitionManagerOptions.SkipBlobContainerCreation = true を見ましたが、これは役に立ちませんでした。

そうでない場合、このジャンクの蓄積を避けるために設定する必要があるストレージ アカウントの設定はありますか?

ありがとう！

Azure イベント ハブを使用して、Android アプリケーションにプッシュ通知機能を実装したいと考えています。初心者なので、どのように進めたらよいのかよくわかりません。

期待どおりに動作している送信者 (Azure イベント ハブの送信者) として Raspberry Pi を使用しています。Raspberry Pi から送信されたメッセージを受信するために、Android デバイスでそれを (Azure イベント ハブの受信側として) 処理できるようにします。

ここで使用できると思われるBroadcast Receiverの概念に出会いました。私が正しい軌道に乗っているかどうかの情報が必要であり、いくつかの例が提供されている場合は感謝します.

これを達成するための最適な方法を提案してください。

Raspberry Pi から Azure イベント ハブにイベントを送信するためのコード:

これらのリンクを参照して、期待どおりに動作している .net コンソール アプリケーションに送信者と受信者を実装しました。Androidでも同じものを実装する必要があります。

https://azure.microsoft.com/en-in/documentation/articles/event-hubs-csharp-ephcs-getstarted/

また、Azue Python SDK ( https://pypi.python.org/pypi/azure-servicebus/0.20.1 )を使用して送信者を実装することもできます。

10 のパーティションと 10 のスループット ユニットを持つイベント ハブ経由で 100 万の小さなメッセージを送信しようとしています。

その目的のために、私は javax.jms.MessageProducer を使用しています。

私の質問は、Azure Event Hubs UI でエラーが表示されるのに、ServerBusy (またはその他の) 例外をキャッチできないのはなぜですか? Java ライブラリが、メッセージの再送信を含め、例外を外部にまったく公開せずに既に処理している可能性がありますか?

また、一般的に言えば、Java プロデューサでの ServerBusy エラー処理のベスト プラクティスは何でしょうか? (プロデューサが常に TU ごとに 1000 を超えないメッセージを送信するように、レート リミッタを実装するか、ServerBusy 例外をキャッチする際に再送信ポリシーを実装するか...)