Stream Analytics クエリをライブ ストリーム入力に対してローカルでテストすることは、クエリ ロジックの精度と効率性を確保するための重要な手順です。 Visual Studio Code (VS Code) 用の Azure Stream Analytics (ASA) 拡張機能を使用すると、このテストをシームレスに実行するために必要なツールを利用できます。 この記事では、環境のセットアップ、ライブ ストリーム入力の構成、および徹底的なテストのためのクエリのローカル実行の手順について説明します。
[前提条件]
- .NET Core SDK をインストールし、Visual Studio Code を再起動します。
- このクイックスタートに従って、Visual Studio Code を使用して Stream Analytics ジョブをインストールして作成します。
ライブ ストリーム入力を定義する
Stream Analytics プロジェクトの [Inputs ] フォルダーを右クリックし、[ ASA: Add Input] を選択します。
または、 Ctrl+Shift+P を押してコマンド パレットを開き、「 ASA: Add Input」と入力します。 次に、入力ストリームを処理するためのクエリスクリプトを選択します。
ドロップダウンリストからライブ入力ソースの種類を選択し、 [Azure サブスクリプションから選択 ] を選択し、入力ソースの名前を入力します。
Input フォルダーの下に新しい JSON ファイルが作成されます。 ファイルを開き、 サブスクリプションから選択 して、Event Hubs 入力の構成に役立てます。
[ データのプレビュー ] を選択して、ライブ入力が正常に構成されたかどうかを検証します。
クエリをローカルで実行する
クエリ ファイルを開き、 [ ローカルで実行 ] を選択するか、メニュー バーの [再生 ] ボタンを選択して、ローカル実行モードを構成するための [ローカル実行オプション ] ウィンドウを開きます。
![クエリ エディターで [Run locally] を選択している VS Code 拡張機能のスクリーンショット。](media/vscode-local-run-live-input/run-locally.png)
[ ライブ入力とローカル出力を使用 ] を選択して、ライブ入力ストリームに対してジョブをローカルに実行し、出力結果をローカル フォルダーに生成します。 次に、[ 実行 ] を選択して、ジョブをローカルで実行し始めます。
ローカル テスト ウィンドウが開いて、3 秒ごとに更新されていることがわかります。 出力結果は 、LocalRunOutputs フォルダーに JSON 形式で格納されます。
ローカル テストの入力パーティションの指定
Event Hubs からすべてのデータを取り込むのを避けるために、ローカル テスト中に Event Hubs に特定のパーティションを指定できます。
- [ ローカルで実行 ] を選択して、ローカル実行オプション ウィンドウを開きます。
- [入力パーティション セクションの選択] で、[カスタム] を選択します。
- ローカル テスト用にデータを取り込む特定のパーティション番号を入力します。
パーティションを指定することで、大量のデータを気にすることなく、クエリ ロジックのテストに集中できます。 この機能により、Stream Analytics ジョブのより効率的で的を絞ったテストが可能になります。
Azure にジョブを送信する
クエリのローカルでのテストが完了したら、Stream Analytics プロジェクトを Azure に送信し、クラウドでジョブの実行を開始できます。
- [Azure に送信] オプションを選択するか、クエリ ファイルの [アップロード] ボタンを選択します。
- 送信オプション ウィンドウでは、 Azure の既存のジョブを更新し たり、アップロード用の 新しいジョブを作成したり できます。
- サブスクリプション、リソース グループ、デプロイのリージョンなど、必要な詳細を指定します。
送信プロセスが完了すると、新しいウィンドウでクラウド ジョブを表示できます。 そこから、パフォーマンスを監視し、必要に応じて構成を管理できます。 また、OUTPUTパネルにあるリンクをクリックして、ブラウザでジョブを開くこともできます。
