azure-stream-analytics

1熱

2答えて

Azureストリーム解析は、すべてのパーティションからのデータを読み込みますか？

Azureイベントハブにはスケーラビリティのためのパーティション機能があります。 appサービスを使用してデータを読み取る際に、1つのeventprocessorHostを1つのパーティションに限定することができます。複数のパーティションからのデータを一括して処理する方法はありません。しかし、ストリーム分析を使用している間は、時間に基づいてデータを集計できます。では、データを集約しながらすべての

0熱

1答えて

タンブルウィンドウを使用したAzureストリーム分析クエリ

アプリケーションでは、複数のIoTデバイスがIoTハブにデータを公開します。彼らは部屋でいくつかの読書を出す（例：電力使用）。ここでは、1時間前の領域で消費された総エネルギーを調べてログに記録するという要件があります。午前8時にスイッチが入れられ、60ワットの電力を消費する電球があり、それが8時20分に10分間スイッチオフされたとします。 8時30分に、それは40ワットの電力使用量で淡色にスイ

0熱

1答えて

Iot Hub AzureでpartitionIdまたはpartitionKeyを使用する

私は、IoTデバイスがMQTTプロトコルを使って（メッセージをプッシュするために1つのトピックを使用して）、イベントをAzure IoTハブにパブリッシュするアプリケーションを開発しています。 Stream Analyticサービスを使用してこれらのメッセージを消費する必要があります。そして、ストリーム分析サービスをスケールするには、partitionBy節を使用することをお勧めします。 Azur

1熱

1答えて

Azure Stream Analyticsでの並列処理方法

私の理解が正しい場合は、一度に1つのストリーム分析ジョブのインスタンスしか実行されません。そして、現在のイベントセットで終了した後、次のイベントセットがイベントハブから取得されます。もしそうなら、逐次的です。処理に20ミリ秒かかる場合、他のイベントはその数ミリ秒間待たなければなりません。私はこの一連の操作で生産量が足りるとすればいいのだろうかと思っていましたか？私はPartitionBy節を認

1熱

1答えて

SELECT文字列式は二重引用符ではなく単一文字を認識しますか？

私はAzure Stream Analyticsクエリを作成していますが、定数カラムのヘッダーと値を出力する必要がありました。文字列式をSELECTアイテムとして含めると、単一の（ '）で囲まれている必要があります引用符（ "）、そうでない場合、私はNULLを取得する。 SELECT 'foo' as "bar" INTO ... FROM ... >>> outputs foo as a val

0熱

1答えて

Azureストリーム分析array_agg相当？

ストリームアナリティクスでarray_aggまたはstring_aggに相当するpostgresを実行する方法はありますか？私は数秒ごとに来るデータを持っており、時間枠内で値のカウントを取得したいと考えています。 2秒のスライディングウィンドウで {time:12:01:01,name:A,location:X,value:10} {time:12:01:01,name:B,location:X

1熱

1答えて

Azure Stream Analyticsで静的データとリアルタイムデータを結合する

Stream Analyticsでデータ（Azure SQLに格納されている）とリアルタイムのストリームデータ（IoT Hub経由で取得）を組み合わせる方法を検討しています。私が見つけた1つの方法は、BLOBストレージを使用してSQL Azureデータをコピーし、それを入力データ型「参照データ」として使用し、Stream AnalyticsのクエリエディタJOINでうまく動作するストリーミングデー

1熱

2答えて

Azure関数のエラーをトリガーする方法カスタムエラー応答を伴うHTTPトリガー

httpコールをnodejs azure関数に失敗させ、カスタムエラー応答を含める方法が見つかりません。 context.doneを（）を呼び出すは、カスタム応答が可能になります（ただし、アプリケーションの洞察に障害として示されていない）、障害を作成しない呼び出すcontext.done（真、XXX）、それだけには一般的なエラーを返します。ユーザー（私はXXXに入れて何に関係なく）： {"id

0熱

2答えて

Azureストリーム解析データのバッチをPython MLパイプラインに送信する方法はありますか？

私は、イベントハブからのストリームアナリティクスを使用してデータを取得する際に、機械学習タスクをいくつか実行したいと考えています。しかし、私のデータ処理パイプラインと予測サービスの多くは、Pythonで行われています。処理のためにPythonスクリプトに時間チャンクされたデータを送る方法はありますか？ Azure MLスタジオの機能は、データの単一行で動作するように見え、ストリームアナリティクスで

0熱

1答えて

大規模な参照データ

私のAzure Streaming Analyticsジョブでは、IPアドレスをジオロケーションにしようとしています。私が使用しているリファレンスは約165 MBです。参照データブロブは、100 MBそれぞれに限定されるものではdocumentation状態以下の通りである：ストリーム解析は、パスパターンプロパティを使用して複数の参照BLOBを処理することができる100ブロブあたりMBが、ジョブ