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.

は、今私は2つのAzureストレージのテーブルを持っていると言うMachine1RecordMachine2Recordを言います。 これで、マシンM1レコードがテーブルMachine1Recordにストアされ、マシン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" 

しかし、いずれも動作していません。ありがとう。

答えて

0

私が正しく理解していれば、ストリームアナリティクスへの2つの入力として1つのイベントハブを使用します。

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

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

SELECT * 
INTO machine2output 
FROM BothMachines 
PARTITION BY MachineName 
WHERE MachineName = "M2" 
+0

こんにちは、ありがとう、私はすでにそれを行っているが、私は上記のストリーム解析分析ウィンドウでjsonを定義し、ちょうどテストボタンをクリックするので、それは動作していないあなたに何の出力も与えません。 – JARVIS

+0

このリンクも表示されている場合は、これを達成するために同じイベントハブの2つの異なる入力エイリアスを作成する必要があることが示唆されていますが、それもworking.httpsではありません://social.msdn.microsoft.com/Forums/en-US/ aad1b6a9-15e4-4716-9c07-6705d0702c74/analytics-query?forum = AzureStreamAnalyticsを使用する複数のパーティションキーを使用する – JARVIS

0

こんにちは、私は私がここでやっていた唯一の間違いはclause.Iだけで二重引用符を削除し、このように単一引用符を使用する場所で、二重引用符でM1とM2を渡しているこの問題を解決 -

SELECT * INTO machine1output From machine1input where MachineName = 'M1' 
SELECT * INTO machine2output From machine1input where MachineName = 'M2' 

そして、それは完全に働いています。

関連する問題