問題タブ [azure-eventhub]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票する
4 に答える
8750 参照

azure - Azure Event Hub からすべてのメッセージをログに記録する最も簡単な方法

イベント ハブに出力するサービスを使用しています。

その出力を保存し、Apache Spark で実行されるバッチ ジョブによって 1 日 1 回読み取られるようにします。基本的には、すべてのメッセージを BLOB にダンプするだけです。

イベント ハブから Blob Storage へのメッセージをキャプチャする最も簡単な方法は何ですか?

私たちが最初に考えたのは Streaming Analytics の仕事でしたが、生のメッセージ (CSV/JSON/Avro) を解析する必要があり、現在の形式はそれらのどれでもありません。


更新メッセージ形式を変更することで、この問題を解決しました。メッセージをブロブに保存する影響の少ない方法があるかどうかを知りたいです。Streaming Analytics が登場する前に、EventHub にはこの問題に対する解決策がありましたか?

0 投票する
2 に答える
3056 参照

python - Python SDK を使用して Azure Event Hubs に変数を送信する方法

温度値を含む変数がある場合、ServiceBusService.send_event を使用してどのように送信できますか?

0 投票する
0 に答える
256 参照

amqp - Null メッセージによる EventHub レシーバーの RecieveTime の問題

ラッパーを使用して、特定のパーティションを持つAzureSBLiteメッセージをポーリングしています。eventhubEventdata は 1 つのイベント ハブに送信され、ストリーム分析はそこから読み取られます。ストリーム分析を処理した後、特定のパーティション内の別のイベント ハブに書き込みます。

受信部分は通常60-150s、受信メソッドを使用していますが、ここではそうではありません。ラッパーの下で何が起こっているのか、どこにあるのかわかりません。の出力を確認しstreamanalyticsました。ほぼ瞬時ですが、レシーバーは何も取得していません。


受信者コード


ここに画像の説明を入力

同じ EventHub で試してみましたが、2 つの異なるパーティションの方が悪いです。


ここに画像の説明を入力

注: Azure.SeriveBus は Windows 10 IoT Core ではサポートされていないため、EventProcessorHost を使用できません。

0 投票する
1 に答える
202 参照

azure - Azure Stream Analytics によるアセット トラッキング

イベント ハブと、データを Power BI に送信するストリーム分析ジョブがあります。イベント ハブ / アセット トラッキングを構成する最良の方法は何だろうと考えていました。

たとえば、複数のクライアントがイベント ハブに送信している -> ストリーム分析ジョブがあり、特定の ID を持つクライアントがオフラインになるかどうかを判断できるようにしたいですか?

乾杯!

0 投票する
1 に答える
1200 参照

python - REST API 使用時の Azure イベント ハブのパーティションの選択

Python と残りの API を使用して Azure Event Hub にメッセージを送信しようとしていますが、失敗したいくつかの実験の後、動作するコードが見つかりました (以下を参照) が、イベントを送信するパーティションを選択できるようにしたいと考えています。

残りの API を使用してこれを行うことは可能ですか?

0 投票する
3 に答える
4310 参照

java - REST API を介してイベント ハブでメッセージを送信および使用する方法

Azure EventHub は初めてです。REST API を介して AzureEventHub からメッセージを送受信できる単純なプロトタイプを作成したいと考えていました。

メッセージの生成と消費のために EventHub で公開されている REST API を使用する方法を示すコード スニペットを提供してください。

0 投票する
2 に答える
2481 参照

node.js - ノード js を使用して Azure EventHub データを取得する方法

私はマイクロソフト イベント ハブの初心者です。eventHubノードjs(refrence )を使用してデータを正常に送信しています。

イベント ハブからデータを受信して​​表示する方法は? 何か案が?

0 投票する
2 に答える
454 参照

c# - EventHub と Async を使用した要求のバースト モード

デバイスwavから にオーディオ ファイル( )を送信しようとしています。メッセージごとに64Kbのサイズ制限があるため、各メッセージはバイト配列にチャンクされて に送信されます。クライアントからの最大送信レート[しきい値を超えない]を達成しようとしています。IoTEventhubEventhub7kbEventhub

ライブ オーディオを録音し、ファイル ストリームに保存して、送信用にチャンクします。カスタムストリーム実装でこの部分を回避しました

しかし、ここで REST 実装を使用すると、同じ速度でバイトを送信できません。送信にはサードパーティのラッパーを使用しているため、その側ではできません。

しかし、スレッドをスパンして、対話中にアプリケーションを応答させることができるので、使用します

タスクがタスクの結果も完了するのを待ちたくありませんが、これを行うと、ほとんどの要求が " Request Timed out" になり、それらの要求のためにアプリケーションが動かなくなります。

とにかく、スレッドをブロックせずにアプリケーションをレスポンシブにすることができますか?


編集:現在適用Parallel.Invokeされており、単一のメッセージを失うことはなく、アプリケーションも応答しますが、送信ドロップは2〜3メッセージ/秒に大幅に減少します

非同期を使用するのではなく、マルチ スレッド モデルに切り替える必要があります。次のようなシムラーの質問が見つかりました .Net 4.5 の async HttpClient は負荷の高いアプリケーションには適していませんか?