問題タブ [azure-eventhub]

Azure Web アプリケーションを構築しています。アクティビティ ログを Azure Event Hub に送信したいと考えています。アプリケーション ホストとイベント ハブの間の接続が失われるとどうなりますか? イベント ハブ クライアントは何らかのローカル キューを実装していますか?

イベント ハブに 1 つのスループット ユニット (1000 メッセージ/秒または 1Mb/秒を許可) があり、1000 メッセージ/秒を超える送信を試みた場合、Azure Python SDK は例外をスローするか、または通知する何らかのリターン コードを持っていますか?クォータを超えたということですか？

Azure Event Hubs からイベントを使用できるように、NodeJS 用の安定した AMQP 1.0 クライアントを探しています。

https://github.com/noodlefrenzy/node-amqp10を使用してみましたがmalformed payload: Unknown code prefix: 0x30、malformed payload: Unable to decode bytes from message body: 005375b00002810c5b7b226576656e7474797065223(...)などのメッセージを含む特定のペイロードで散発的にチョークします。

NodeJS で安定した AMQP 1.0 クライアントを提供するために、人々が提供できる指示をいただければ幸いです。それ以外の場合、Azure は開発者ベース全体をサポートできていないように思われるため、これまでに 1 つを見つけることができなかったことに驚いています。

Python とプロトン ライブラリを使用して、サブスクライバー (メッセージを受信するため) として Azure イベント ハブに接続しようとしています。

サンプルコードを見つけて、最終的に次のようになりました。

pipを使用してインストールされたpython-qpid-proton（0.10）を使用して、macosxでこのコードを実行しています。

しかし、イベントハブのメッセージを取得できません。動作する別のスクリプトから毎分メッセージを送信していることを知っています。印刷した次の出力を取得します

amqps://NAME:KEY@clienteventhub-ns.servicebus.windows.net/NAME/ConsumerGroups/$Default/Partitions/0 にサブスクライブしました amqps://NAME:KEY@clienteventhub-ns.servicebus.windows.net/ にサブスクライブしましたNAME/ConsumerGroups/$Default/Partitions/1 amqps://NAME:KEY@clienteventhub-ns.servicebus.windows.net/NAME/ConsumerGroups/$Default/Partitions/2 にサブスクライブしました amqps://NAME:KEY@ にサブスクライブしましたclienteventhub-ns.servicebus.windows.net/NAME/ConsumerGroups/$Default/Partitions/3 amqps://NAME:KEY@clienteventhub-ns.servicebus.windows.net/NAME/ConsumerGroups/$Default/Partitions/4 にサブスクライブしましたamqps://NAME:KEY@clienteventhub-ns.servicebus.windows.net/NAME/ConsumerGroups/$Default/Partitions/5 にサブスクライブしました amqps://NAME:KEY@clienteventhub-ns.servicebus.windows.net/ にサブスクライブしましたNAME/ConsumerGroups/$Default/Partitions/6 amqps://NAME に登録:KEY@clienteventhub-ns.servicebus.windows.net/NAME/ConsumerGroups/$Default/Partitions/7

このコードが機能しない理由を知っていますか? ありがとう

自分のイベント ハブ EventProcessorHost ワーカー ロールを発行できません。インスタンスが起動しません。表示されるエラーは次のとおりです。

これは基本的に、Kirk Evans ブログの例をコピーしたものです: http://blogs.msdn.com/b/kaevans/archive/2015/02/24/scaling-azure-event-hubs-processing-with-worker-roles.aspx

本当に私を惹きつけている部分は、私が以前にこれをやったことがあるということです. 彼の同じ例を使用して、別のサービス バス/イベント ハブに発行しました。そのため、その「古い」プロジェクトを使用して、いくつかの URL をリダイレクトすることで、この新しいサービス バス / イベント ハブに投稿したところ、すべて正常に動作しました。新しいプロジェクトを使用して新しいサービス バス/イベント ハブに投稿しようとすると、ダイスはありません。私はこの新しいプロジェクトを、彼が使用しているのと同じコードだけに落とし込みました...まだ灘です。

すべてが 4.5.1 (4.5.2 ではない) であることを確認しました。ライブラリは同じように見えます...これを 2 日間見ていて、気が狂いそうです!

更新: OK、ライブラリはすべて同じではありませんでした...そして問題があるようです。ServiceBus を 3.0.6 (3.0.7 ではない) に、Azure Storage Client を 6.0.0 (6.1.0 ではない) に、EventProcessorHost を 2.0.3 (2.0.5 ではない) に戻すと、動作させることができます。

そのため、これらのライブラリの最新バージョンの組み合わせがどこかで競合しています。

さまざまな Azure データ ストレージのフレーバーに関する情報がたくさんありますが、特定のシナリオについてアドバイスをお願いしたいと思います。

Azure テクノロジ、特に Service Bus/Event Hubs とデータ ストレージ プラットフォームに精通するためのペット プロジェクトをまとめています。私が作成したいシステムは非常に単純です: イベントの適度な負荷 (IoT スケールではない) を受け入れ、それらを保持し、「ユーザー A は過去の日/週/月/中にタイプ X の N 個のイベントを持っていた」などの集計データを利用できるようにします。等。' レポートとして。

データが非常に構造化され (ユーザー、ユーザー グループ、イベントなど)、集計機能が必要になることを考えると、リレーショナル ストレージが最も適している可能性がありますが、費用は高くなります。

私が検討したもう 1 つの代替案は、ストリーム分析などを使用してほぼリアルタイムで集約データを維持することですが、これがデータ ウェアハウス風のソリューションと比較してやり過ぎかどうかはわかりません。

任意の提案/ヘルプをいただければ幸いです。

ジョン

Microsoft Azure
を初めて使用します。イベント ハブ Microsoft Azure でデータを更新する必要があります。
これは、イベント ハブでデータを送信するためのコードです。

それをしてもいいですか ？
助けて。
ありがとう。