0

異なるパーティション キー/パーティション ID を持つ 2 つのイベント データをイベント ハブに送信するシナリオがあります。

ここで、ストリーム分析で、同じ接続文字列 ( machine1input と machine2input など) を持つ 2 つの入力エイリアスと 2 つの異なる出力エイリアスを作成しましたが、ここでは、各出力エイリアスが別々のテーブル ストレージを指しています。

今、私のイベントデータはこのようなものです。

{
  "MachineName": "M1",
  "Date": "2016-05-26T13:35:30.1557995+05:30"
}
{
  "MachineName": "M2",
  "Date": "2016-05-26T13:35:30.1557995+05:30"
}

ここでは、MachineName-M1 を別のパーティション (たとえば 1) に送信し、MachineName-M2 を別のパーティション (たとえば 2) に送信しています。

Machine1Recordこれで、とという 2 つの Azure ストレージ テーブルができMachine2Recordました。Machine1Recordここで、マシン M1 レコードがテーブルに格納され、マシン M2 レコードがMachine2Recordデータとして自動的にテーブルに格納されるように、ストリーム分析クエリ ウィンドウにクエリを記述します。

このようなものを実現するために、多くのクエリを試しました。

SELECT * INTO machine1output From machine1input PARTITION BY PartitionId where PartitionId = "1"
SELECT * INTO machine2output From machine2input PARTITION BY PartitionId where PartitionId = "2"
SELECT * INTO machine1output From machine1input where MachineName = "M1"
SELECT * INTO machine2output From machine2input where MachineName = "M2"

しかし、どれも機能していません。これについて助けてください。ありがとう。

4

2 に答える 2

0

私の理解が正しければ、ストリーム分析への 2 つの別々の入力として、単一のイベント ハブを使用します。

イベント ハブからの単一の入力をストリーム分析ジョブに使用できます。次に、次のように、入力ストリームから 2 つの出力を作成できます。

SELECT * 
INTO machine1output
FROM BothMachines
PARTITION BY MachineName 
WHERE MachineName = "M1"

SELECT * 
INTO machine2output
FROM BothMachines
PARTITION BY MachineName 
WHERE MachineName = "M2"
于 2016-05-26T15:34:28.323 に答える