クイックスタート: Azure Portal を使用して Stream Analytics ジョブを作成する

このクイックスタートでは、Azure portal で Stream Analytics ジョブを作成します。リアルタイムストリーミングデータを読み取り、温度が 27 を超えるメッセージをフィルター処理する Stream Analytics ジョブを定義します。 Stream Analytics ジョブは、IoT Hub からデータを読み取り、データを変換し、Azure BLOB ストレージ内のコンテナーに出力データを書き込みます。このクイックスタートで使用される入力データは、Raspberry Pi オンラインシミュレーターを使用して生成されます。

前提条件

Azure サブスクリプションをお持ちでない場合は、無料アカウントを作成してください。

入力データを準備する

Stream Analytics ジョブを定義する前に、入力データを準備します。このソリューションでは、リアルタイムセンサーデータが IoT Hub に取り込まれ、後でジョブ入力として構成されます。ジョブで必要な入力データを準備するには、次の手順を完了します。

Azure portal にサインインします。
[リソースの作成] を選択します。 [リソースの作成] ページで、[モノのインターネット]>[IoT Hub] を選びます。
[IoT Hub] ページで、次の手順のようにします。
1. [サブスクリプション] で、Azure サブスクリプションを選択します。
2. [リソースグループ] で、既存のリソースグループを選ぶか、新しいリソースグループを作成します。
3. [IoT ハブ名] に、IoT ハブの名前を入力します。
4. [リージョン] で、最も近いリージョンを選びます。
5. サブスクリプションで引き続き利用できる場合は、[ レベル] で [ Free] を選択します。詳細については、「IoT Hub の価格」を参照してください。
6. [1 日あたりのメッセージの制限] では、既定値をそのまま使用します。
7. ページの下部にある [Next: Networking](次へ: ネットワーク) を選択します。
[Review + create](レビュー + 作成) を選択します。 IoT Hub の情報を確認して、[作成] を選択します。お客様の IoT ハブの作成には数分かかることがあります。 [通知] ウィンドウで進行状況を監視できます。
リソース (IoT ハブ) が作成されたら、[リソースに移動] を選んで IoT ハブのページに移動します。
[IoT Hub] ページの左側のメニューで [デバイス] を選んでから、[+ デバイスの追加] を選びます。
[デバイス ID] を入力し、[保存] を選択します。
デバイスが作成されると、 IoT デバイス の一覧にデバイスが表示されます。表示されない場合は、ページの [最新の情報に更新] ボタンを選びます。
一覧からお使いのデバイスを選択します。
デバイスページで、プライマリ接続文字列の横にあるコピーボタン選択し、後で使用するためにメモ帳に保存します。

IoT シミュレーターを実行する

Raspberry Pi Azure IoT オンラインシミュレーターを開きます。
15 行目のプレースホルダーを、前のセクションで保存した Azure IoT Hub デバイス接続文字列に置き換えます。
[実行] を選択します。出力には、IoT Hub に送信されるセンサーデータとメッセージが表示されます。

BLOB ストレージを作成する

Azure portal の左上隅から [リソースの作成] を選択します。左側のメニューの [カテゴリ] の下にある [ストレージ] を選択し、続いて [ストレージアカウント] を選択します。
[ ストレージアカウント ] ページで、[ 作成 ] を選択してストレージアカウントの作成を開始します。
[ ストレージアカウントの作成 ] ページで、次の手順に従います。
1. ストレージアカウント名、場所、およびリソースグループを入力します。お客様が作成した IoT ハブと同じ場所およびリソースグループを選択します。次に、ページの下部にある [確認] を選択します。
2. [優先ストレージの種類] で、[Azure Blob Storage] または [Azure Data Lake Storage Gen2] を選択します。このオプションを使用すると、Stream Analytics ジョブの出力にストレージアカウントを使用できます。
3. ページ下部にある [確認と作成] を選択します。設定を確認します。
[ 確認と作成 ] ページで設定を確認し、[ 作成 ] を選択してアカウントを作成します。
リソースが作成されたら、[リソースに移動] を選んで [ストレージアカウント] ページに移動します。
[ ストレージアカウント ] ページで、左側のメニューの [コンテナー ] を選択し、[ + コンテナーの追加] を選択します。
[新しいコンテナー] ページで、コンテナーの名前 (container1 など) を指定して、[作成] を選びます。

Stream Analytics のジョブの作成

同じブラウザーウィンドウの別のタブまたは別のブラウザーウィンドウで、Azure portal にサインインします。
左側のメニューから、 [すべてのサービス] を選択します。 [カテゴリ] の下の [分析] を選択します。 Stream Analytics ジョブの上にマウスポインターを置き、+選択するか、ポップアップウィンドウで [+ 作成] を選択します。
新しい Stream Analytics ジョブでは、次の手順に従います。
1. [サブスクリプション] で、Azure サブスクリプションを選択します。
2. [リソースグループ] で、このクイックスタートで前に使ったのと同じリソースを選びます。
3. [名前] に、ジョブの名前を入力します。 Stream Analytics ジョブ名には、英数字、ハイフン、アンダースコアのみを使用することができます。長さは 3 文字以上 63 文字以下でなければなりません。
4. [ホスティング環境] で、[クラウド] が選ばれていることを確認します。 Stream Analytics ジョブは、クラウドまたはエッジにデプロイすることができます。 [クラウド] にすると Azure Cloud にデプロイでき、[Edge] オプションにすると IoT Edge デバイスにデプロイできます。
5. [ストリーミングユニット] で、[1] を選びます。ストリーミングユニットとは、ジョブの実行に必要なコンピューティングリソースのことです。ストリーミングユニットのスケーリングについては、ストリーミングユニットの理解と調整に関する記事を参照してください。
6. ページ下部にある [確認と作成] を選択します。
  
  $**[New Stream Analytics job]$新しい Stream Analytics ジョブ$ ページを示すスクリーンショット。$
[ 確認と作成] で設定を確認し、[ 作成 ] を選択して Stream Analytics ページを作成します。
デプロイのページで、[リソースに移動] を選んで [Stream Analytics ジョブ] ページに移動します。

ジョブの入力を構成する

このセクションでは、Stream Analytics ジョブへの IoT Hub デバイスの入力を構成します。クイックスタート内の前のセクションでお客様が作成した IoT ハブを使用します。

[Stream Analytics ジョブ] ページで、左側のメニューの [ジョブトポロジ] で [入力] を選択します。
入力ページで、IoT Hub>入力追加 を選択します。
[IoT Hub] ページで、次の手順のようにします。
1. [入力のエイリアス] に「IoTHubInput」と入力します。
2. [サブスクリプション] で、前に作成した IoT ハブが含まれるサブスクリプションを選びます。このクイックスタートでは、同じサブスクリプションに IoT ハブを作成することを前提としています。
3. [IoT Hub] で、自分の IoT ハブを選びます。
4. [保存] を選んで、Stream Analytics ジョブの入力設定を保存します。

ジョブの出力を構成する

左側のメニューの [ジョブトポロジ] で [出力] を選択します。
出力ページで、Blob Storage/ADLS Gen2 >出力の追加 を選択します。
[Blob Storage または ADLS Gen2] の [新しい出力] ページで、次の手順のようにします。
1. [出力のエイリアス] に「BlobOutput」と入力します。
2. [サブスクリプション] で、前に作成した Azure ストレージアカウントが含まれるサブスクリプションを選びます。このクイックスタートでは、同じサブスクリプションにストレージアカウントを作成したことを前提としています。
3. ストレージアカウントの場合は、ストレージアカウントを選択します。
4. [コンテナー] で、BLOB コンテナーがまだ選ばれていない場合は選びます。
5. [認証モード] で、[接続文字列] を選びます。
6. ページの下部にある [保存] を選んで、出力の設定を保存します。

変換クエリを定義する

左側のメニューの [ジョブトポロジ] で [クエリ] を選択します。
クエリウィンドウに次のクエリを入力します。この例では、クエリによって IoT Hub からデータが読み取られ、BLOB 内の新しいファイルにそれがコピーされます。
```
SELECT *
INTO BlobOutput
FROM IoTHubInput
WHERE Temperature > 27
```
ツールバーの [クエリの保存] を選びます。

Stream Analytics ジョブを開始して出力をチェックする

Azure portal でジョブの概要ページに戻り、ジョブの開始を選択します。
[ジョブの開始] ページで、[ジョブ出力の開始時刻] に [今すぐ] が選ばれていることを確認し、ページの下部にある [開始] を選びます。
数分後、ポータルで、ジョブの出力として構成したストレージアカウントとコンテナーを見つけます。コンテナーに出力ファイルが表示されるようになりました。ジョブが初めて開始されるまでに数分かかります。開始後も、データが到着しても引き続き実行されます。
ファイルを選び、[BLOB] ページで [編集] を選んでファイルの内容を表示します。

リソースのクリーンアップ

リソースが不要になったら、リソースグループ、Stream Analytics ジョブ、およびすべての関連リソースを削除します。ジョブを削除すると、ジョブが使用するストリーミングユニットの課金が停止します。今後ジョブを使用する予定の場合は、ジョブを停止し、必要に応じて後で再起動できます。このジョブを使い続けない場合は、以下の手順のようにして、このクイックスタートで作成したすべてのリソースを削除します。

Azure Portal の左側のメニューで [リソースグループ] を選択し、作成したリソースの名前を選択します。
リソースグループのページで [削除] を選択し、削除するリソースの名前をテキストボックスに入力してから [削除] を選択します。
Raspberry Pi Azure IoT Online Simulator アプリで、ウィンドウの右下の [実行] の隣にある [リセット] を選択します。

次のステップ

その他の入力ソースの構成やリアルタイム検出の実行について学習するには、次の記事に進んでください。

Azure Stream Analytics を使用したリアルタイムの不正行為の検出

フィードバック

このページはお役に立ちましたか?

Last updated on 2026-02-20