Stream Analytics を使用してデータを移動する
Azure Stream Analytics は、複数のソースからの高速ストリーミング データを同時に処理するように設計されたリアルタイムのイベント処理エンジンです。 データを集計、分析、変換、さらには他のデータ ストアに移動して、より深く詳細に分析することができます。
セットアップ
Azure Stream Analytics は、Azure Cosmos DB for NoSQL を含む複数の出力シンクをサポートします。
注意
この時点でサポートされているのは NoSQL API のみです。
構成
Azure Cosmos DB for NoSQL 出力は、サブスクリプション内のアカウントを選択するか、資格情報を指定することによって構成され、通常は次のものが含まれます。
| プロパティ | 説明 |
|---|---|
Output alias |
クエリでこの出力を参照するためのエイリアス |
Account ID |
アカウント エンドポイント URI |
Account Key |
アカウント キー |
Database |
データベース リソースの名前 |
Container name |
コンテナーの名前 |
出力シンクを使用する前に、Azure Cosmos DB for NoSQL アカウントにデータベースとコンテナーが既に存在している必要があります。
Azure Cosmos DB に書き込む
Azure Stream Analytics からのクエリ結果は、Azure Cosmos DB for NoSQL に書き込まれるときに JSON 出力として処理されます。
また、id フィールドの値に基づいて、項目が Azure Cosmos DB for NoSQL にアップサートされます。 通常、項目は Azure Cosmos DB for NoSQL に挿入されます。 同じ一意の ID を持つ項目が既に存在する場合、操作は挿入操作ではなく更新操作と見なされます。