Azure Stream Analytics の入力について
Azure Stream Analytics ジョブは、1 つまたは複数のデータ入力に接続します。 各入力は、既存のデータ ソースへの接続を定義しています。 Stream Analytics が受け取るデータは、Event Hubs、IoT Hub、Blob ストレージなど、各種のイベント ソースから着信します。 各ジョブのために記述するストリーミング SQL クエリ内では、入力は名前によって参照されます。 クエリでは、複数の入力を結合してデータをブレンドするか、参照データへの参照を使用してストリーミング データを比較し、結果を出力に渡すことができます。
Stream Analytics には、入力として次の 4 種類のリソースを使用する優れた統合機能が組み込まれています。
これらの入力ソースは、Stream Analytics ジョブと同じ Azure サブスクリプションに存在していても、異なるサブスクリプションに存在していてもかまいません。
Stream Analytics ジョブの入力を作成、編集、テストするには、Azure portal、Azure PowerShell、.NET API、REST API、Visual Studio、Visual Studio Code を使用できます。
Note
最良のローカル開発エクスペリエンスを実現するためには、Stream Analytics Tools for Visual Studio Code を使用することを強くお勧めします。 Stream Analytics Tools for Visual Studio 2019 (バージョン 2.6.3000.0) には既知の機能差があり、それは今後改善されません。
ストリームと参照入力
データがそのデータ ソースにプッシュされると、Stream Analytics ジョブによって使用され、リアルタイムで処理されます。 入力は 2 つの種類に分けられます。
- データ ストリーム入力
- 参照データ入力。
データ ストリーム入力
データ ストリームは、時間をかけて受け取る、制約のない一連のイベントです。 Stream Analytics のジョブには、少なくとも 1 つのデータ ストリーム入力を含める必要があります。 Event Hubs、IoT Hub、Azure Data Lake Storage Gen2、BLOB ストレージがデータ ストリームの入力ソースとしてサポートされています。 Event Hubs は、複数のデバイスとサービスからイベント ストリームを収集するために使用されます。 これらのストリームには、ソーシャル メディア アクティビティ フィード、株式取引情報、またはセンサーからのデータが含まれている場合があります。 IoT Hub はモノのインターネット化 (IoT) シナリオ内で、接続されているデバイスからデータを収集するように最適化されています。Blob Storage は、ストリームとしてバルク データ (ログ ファイルなど) を取り込むための入力ソースとして使用できます。
ストリーミングによるデータ入力の詳細については、「Stream Analytics に入力としてデータをストリーム配信する」を参照してください。
参照データ入力
Stream Analytics は、"参照データ" と呼ばれる入力もサポートします。 参照データは、完全に静的であるか、ゆっくりと変化しているかのいずれかです。 これは通常、相関関係の関連付けと参照を実行するために使用されます。 たとえば、SQL の結合を実行して静的な値を参照する場合と同様に、データ ストリーム入力のデータを参照データのデータに結合できます。 Azure Blob Storage、Azure Data Lake Storage Gen2、Azure SQL Database が現在、参照データの入力ソースとしてサポートされています。 参照データ ソースの BLOB には、クエリの複雑さと割り当てられたストリーミング ユニットに応じて、最大 300 MB のサイズ制限があります。 詳細については、参照データのドキュメントのサイズ制限に関するセクションを参照してください。
参照データ入力に関する詳細については、「Stream Analytics での参照に参照データを使用する」を参照してください。