azure-eventhub

2熱

1答えて

私はデータを送信するAzure EventHubを持っています。コンソールアプリケーション（フレームワーク4.6.1）で次のコードを使用すると、完全に実行されます。私はAsp.Netアプリケーションでそれを置けば eventHubClient = EventHubClient.CreateFromConnectionString(myConnString); Console.Wri

1熱

1答えて

Azure関数 - 結果を出力せずに処理されたメッセージに何が起こりますか？

私はAzure関数を書いて、それをIoTハブのメッセージングエンドポイントに接続して、すべての受信メッセージの関数をトリガーしました。この機能の目的は、セルラー伝送の前にGZIPを使用して以前に圧縮されたメッセージを解凍することです。現在、私たちは、クラウドに送信するデバイスを圧縮していません。送信コストを削減するために、圧縮を追加する予定です。現在、ストリームアナリティクスを使用して、ストリー

1熱

1答えて

AzureイベントハブとAzure関数を使用したパイプライン処理

azureイベントハブの新機能であり、にEventHubs/azureを使用してパイプライン処理を実装するオプションがあります機能？イベントハブを経由してくるデータストリームがあります。いくつかのコンポーネントがあり、各コンポーネントは特定の機能を実行し、その結果を次のコンポーネントに渡します。次のコンポーネントは、イベント元のデータと以前のコンポーネントから生成された結果（シーケンシングの依

2熱

1答えて

Azure EventHubの再試行ロジックPartitionedSender

Azureイベントハブからデータを送信または受信しています。要件メッセージをコンシューマが順番に処理する必要があるため、私はPartitionSenderに参加し、常に同じパーティションにイベントを送信することに決めました。 https://docs.microsoft.com/en-us/azure/event-hubs/event-hubs-availability-and-consisten

0熱

1答えて

イベントハブ（サービスバス）のグローバルシーケンス番号

Azureイベントハブ（サービスバスの一部）にイベントのグローバルシーケンス番号があるかどうか知りませんか？シーケンスNoとEventDataからのオフセットを取得できることはわかっていますが、それはパーティションの順序でしかありません。イベントハブ全体（つまりすべてのパーティション）に渡ってシーケンス番号が必要です。歓声

0熱

1答えて

AzureイベントハブC＃バッチ送信者

C＃からEvent hubにイベントをバッチで送信するオプションはありますか？上記のSendBatch APIは新しいEventHubClientには存在しません。

0熱

2答えて

Azure関数 - eventhubからBlobストレージにイベントを書き込むには

イベントハブからBlobストレージにイベントを移動しようとしています。私はイベントハブにメッセージが来るたびにトリガするためにイベントハブにトリガを作成しました。また、Blob Storageとして出力を設定しました。今、私は関数内でやっていることは次のとおりです。 public static void Run(string myEventHubMessage, out string output

0熱

2答えて

ストリームアナリティクス - 出力が表示されない

Stream Analyticを使用してEventHubデータをSQLデータベースに保存します。出力のテーブルからデータを見るためにクエリを書くと、入力と出力の両方の要求があることがわかりますが、空の行はわずか200行しか見ることができません!! ：。だから私は、これは私がそれを書いた方法です:(私の出力テーブルが空であるので、私は問題は、入力と出力の間ベーテ問い合わせることができると思います。

0熱

1答えて

AzureイベントハブとAzure関数を統合するとイベントがなくなります

Azureイベントハブをシンクとして持つWebhookを持つAzure関数がある例を設定しています。このイベントハブには2つの異なるコンシューマグループがあり、その1つは別のAzureファンクションで使用されます。コードはあまりにも派手ではありません（抜粋は下にあります）が、私は奇妙なパターンを観察しています。公開された2つのメッセージごとに、1回だけ機能をトリガするように見えます。公開ウェブフ

0熱

2答えて

EventHostProcessorの最後のチェックポイントからの消費を再開

EventHostProcessorの実装がある場合、同じプロセッサ内の最後のチェックポイントからイベントを強制的に再生するにはどうすればよいですか？明らかに、私のパーティションは100の深さで、私は10のメッセージを消費しました。このリプレイメソッドを呼び出すと、前に消費した10の最初のメッセージをに返すことになります。 C＃ではStopwatchを使用してこれが可能ですが、同等のJavaは表