私はEventHub -> Stream Analytics Job -> Storage Table/Blob構造体を使用しているこのプロジェクトで作業しており、そのためのユニットテストをいくつか作成したいと思います。ユニットテストAzure EventHub、ストリーム解析ジョブとストレージテーブル
送信者のステータスを確認してクエリが正常に動作するかどうかを確認できますが、プロセス全体が即座に実行されるわけではなく、かなりのものがあるため、データがテーブルストレージに送信されているかどうかを確認できます私がEventHubを叩いた瞬間から、そしてデータがStorageに保存されている瞬間からの長い遅延。
最初に新しいAzureテーブルストレージアカウントを作成し、そのアカウント内に新しいAzureテーブルを作成します。 Stream Analyticsジョブで、テーブルストレージの新しい出力を追加します。出力の詳細を設定するときは、ストレージアカウント、アカウントキー、テーブル名、およびイベント内のどの列名がAzure Tableのパーティションと行キーを表すかを指定する必要があります。例として、私はこのような地雷を設定します。
出力が設定された後、あなたはAzureのテーブル出力にイベントハブからの入力イベントをマップする簡単なストリーム解析クエリを作成することができます。また、イベントハブの入力には「イベントハブ」という名前のSend/Listenパーミッションがあります。クエリは次のようになります。
SELECT
*
INTO
tableoutput
FROM
eventhub
この時点で、Azureポータルの[開始]ボタンを押して、ストリーム分析ジョブを実行します。イベントを生成するには、指示hereに従うが、これにイベントメッセージを変更することができます。
string guid = Guid.NewGuid().ToString();
var message = "pk,rk,value\n" + guid + ",1,hello";
Console.WriteLine("{0} > Sending message: {1}", DateTime.Now, message);
eventHubClient.Send(new EventData(Encoding.UTF8.GetBytes(message)));
は、Azureテーブルの結果を眼球TableXplorerのようなツールをダウンロードして、ストレージアカウントの詳細を入力します。 Azure Tableをダブルクリックすると、次のような表示になります。データがプッシュスルーされるまで、定期的にTableXplorerクエリでF5キーを10〜60秒間押してください。あなたがデータ構造にあなたのイベントのハブコードで生成されたパーティション・キー/行キーの値をプッシュする必要がありますテストプログラムによるユニットについて
をし、労働者を持っている：それは現れるとき、それは次のようになります。ポイントクエリを使用してAzureテーブルをポーリングします。 Azureテーブルの使い方の概要はhereです。