Stream Analytics のノーコードエディターを使用してリアルタイムの Power BI ダッシュボードを構築する

[アーティクル]
04/03/2024

このチュートリアルでは、Stream Analytics のノーコードエディターを使用してリアルタイムデータストリームの集計を計算し、それを Azure Synapse Analytics に格納する方法について説明します。

このチュートリアルでは、次の作業を行う方法について説明します。

イベントハブにデータを送信するイベントジェネレーターをデプロイする
ノーコードエディターを使用して Stream Analytics のジョブを作成する
入力データとスキーマを確認する
グループ化するフィールドを選択し、カウントなどの集計を定義する
結果の書き込み先となる Azure Synapse Analytics を構成する
Stream Analytics ジョブの実行
Power BI でのデータの視覚化

前提条件

始める前に、次の手順が完了していることを確認してください。

Azure サブスクリプションをお持ちでない場合は、無料アカウントを作成してください。
TollApp イベントジェネレーターを Azure にデプロイし、このリンクを使用して TollApp Azure テンプレートをデプロイします。 "interval" パラメーターを 1 に設定します。そして、この手順で新しいリソースグループを使用します。
専用 SQL プールが備わった Azure Synapse Analytics ワークスペースを作成します。

Note

データをデータベースにキャプチャせずにリアルタイムの Power BI ダッシュボードを直接構築する場合は、手順 3 と 4 をスキップして、このガイドに進み、Stream Analytics ジョブによって生成された Power BI データセットを使用してリアルタイムダッシュボードを構築できます。
専用 SQL プールを使って carsummary という名前のテーブルを作成します。これは、次の SQL スクリプトを実行することで行うことができます。
```
CREATE TABLE carsummary   
(  
    Make nvarchar(20),  
    CarCount int,
	times datetime
)
WITH ( CLUSTERED COLUMNSTORE INDEX ) ;
```

ノーコードエディターを使用して Stream Analytics のジョブを作成する

TollApp イベントジェネレーターがデプロイされたリソースグループがある場所を探します。
Azure Event Hubs 名前空間を選択します。
[Event Hubs 名前空間] ページで、左側のメニューの [エンティティ] の下にある [Event Hubs] を選択します。
entrystream インスタンスを選択します。
[機能] セクションの [データの処理] に移動してから、[空のキャンバスを使用して開始] テンプレートの [開始] を選択します。
ジョブに carsummary という名前を付け、[作成] を選択します。
イベントハブの構成ページで、次の設定を確認し、[接続] を選択します。
1. [コンシューマーグループ] で、[既存のものを使用] を選んでから、[既定] を選びます。
2. [シリアル化の種類] で、[JSON] が選ばれていることを確認します。
3. [認証モード] で、イベントハブに接続するために [接続文字列] が使われていることを確認します: 接続文字列。
数秒以内に、サンプルの入力データとそのスキーマが表示されます。必要に応じて、フィールドの削除、フィールド名の変更、データ型の変更を実行することもできます。
コマンドバーで [操作] を選んでから、[グループ化] を選びます。
キャンバスで [グループ化] タイルを選択し、それをイベントハブタイルに接続します。
次のように指定して、[グループ化] タイルを構成します。
1. [集計]: [カウント]。
2. [フィールド]: [作成] (CarModel 内に入れ子になったフィールド)。
3. [追加] を選択します。
4. [設定] セクションで:
  1. [次で集計をグループ化] で、[Make] を選びます。
  2. [時間枠] で、値が [タンブリング] に設定されていることを確認します。
  3. [期間] に、3 分と入力します
  4. ページの下部にある [完了] を選択します。
[グループ化] を選び、ページの下部にある [データのプレビュー] タブでグループ化されるデータを確認します。
コマンドバーで、[操作] を選んでから [フィールドの管理] を選びます。
[グループ化] と [フィールドの管理] タイルを接続します。
[フィールドの管理] ページで、次の手順のようにします。
1. 次の図で示すように、[Make] フィールドを追加して、[追加] を選びます。
2. [追加] ボタンを選択します。
[Manage fields](フィールドの管理) 構成ページの [Add all fields](すべてのフィールドを追加する) を選択します。
フィールドの横にある [...] を選択し、[編集] を選択して名前を変更します。
- COUNT_make を CarCount に
- Window_End_Time を times に
[フィールドの管理] ページで [完了] を選びます。 [Manage fields](フィールドの管理) ページは次の画像のようになります。
[フィールドの管理] タイルを選び、ページの下部にある [データのプレビュー] タブで操作に流れ込むデータを確認します。
コマンドバーで [出力] を選んでから、[Synapse] を選びます。
[Synapse] タイルをキャンバスの [Manage fields](フィールドの管理) タイルに接続します。
[Synapse] 設定ページで、次の手順のようにします。
1. [ジョブストレージアカウント] がまだ設定されていない場合は、リソースグループで Azure Data Lake Storage アカウントを選びます。これは、Synapse SQL がデータウェアハウスにデータを読み込むために使うストレージアカウントです。
2. Azure Synapse Analytics が置かれている Azure サブスクリプションを選びます。
3. 前のセクションで carsummary テーブルを作成するために使った専用 SQL プールのデータベースを選びます。
4. 認証のためのユーザー名とパスワードを入力します。
5. テーブル名として「carsummary」と入力します。
6. [接続] を選択します。 Synapse SQL テーブルに書き込まれるサンプルの結果が表示されます。
[Synapse] タイルを選び、ページの下部にある [データのプレビュー] タブを表示します。データが専用 SQL プールに流れ込むことがわかります。
上部のリボンで [保存] を選択してジョブを保存し、[開始] を選択します。
[Stream Analytics ジョブの開始] ページで、[開始] を選んでジョブを実行します。
ノーコードエディターを使って作成されたすべての Stream Analytics ジョブの一覧が表示されます。 2 分以内に、ジョブは [実行中] 状態になります。ページの [最新の情報に更新] ボタンを選択すると、状態が [作成済み] -> [開始] -> [実行中] に変わります。

Power BI の視覚化を作成する

最新バージョンの Power BI Desktop をダウンロードします。
Azure Synapse SQL 用の Power BI コネクタを使います。
DirectQuery でデータベースに接続し、次のクエリを使ってデータベースからデータをフェッチします
```
SELECT [Make],[CarCount],[times]
FROM [dbo].[carsummary]
WHERE times >= DATEADD(day, -1, GETDATE())
```
[データベース] タブに切り替え、資格情報 (ユーザー名とパスワード) を入力してデータベースに接続し、クエリを実行します。
[読み込み] を選んで、Power BI にデータを読み込みます。
その後、次のように指定して折れ線グラフを作成できます
- X 軸を [times] にする
- Y 軸を [CarCount] にする
- 凡例を [Make] にする。これで公開できるグラフが表示されます。ページの自動更新を構成し、3 分に設定すると、リアルタイムのビューを取得できます。

その他のオプション

Azure Synapse SQL を除き、SQL Database をノーコードエディター出力として使用してストリーミングデータを受信することもできます。次に、Power BI コネクタを使用して、DirectQuery で SQL Database をお使いのデータベースに接続し、リアルタイムダッシュボードを構築します。

また、ストリーミングデータを使用してリアルタイムダッシュボードを構築することもできます。 SQL Database 出力の詳細については、「変換して SQL データベースに取り込む」を参照してください。

リソースをクリーンアップする

Event Hubs のインスタンスの場所を探し、[データの処理] セクションの Stream Analytics ジョブの一覧を確認します。実行中のジョブをすべて停止します。
TollApp イベントジェネレーターのデプロイ時に使用したリソースグループに移動します。
[リソースグループの削除] を選択します。リソースグループの名前を入力して削除することを確認します。

次のステップ

このチュートリアルでは、ノーコードエディターを使用して集計を定義し、結果を Azure Synapse Analytics に書き込む、Stream Analytics ジョブを作成しました。その後、Power BI を使用してリアルタイムのダッシュボードを作成し、ジョブによって生成された結果を確認しました。

Azure Stream Analytics によるノーコードでのストリーム処理

Stream Analytics のノー コード エディターを使用してリアルタイムの Power BI ダッシュボードを構築する