Microsoft Fabric のリアルタイムインテリジェンスの使用を開始する

Microsoft Fabric には、リアルタイムデータストリーム用の分析ソリューションを作成できるリアルタイムインテリジェンスが用意されています。この演習では、Microsoft Fabric のリアルタイムインテリジェンス機能を使用して、株価市場データのリアルタイムストリームを取り込み、分析し、視覚化します。

このラボの所要時間は約 30 分です。

注: この演習を完了するには、Microsoft Fabric テナントが必要です。

ワークスペースの作成

Fabric でデータを操作する前に、Fabric 容量を有効にしてワークスペースを作成する必要があります。

https://app.fabric.microsoft.com/home?experience=fabric の Microsoft Fabric ホームページで、[リアルタイムインテリジェンス] を選択します。
左側のメニューバーで、 [ワークスペース] を選択します (アイコンは 🗇 に似ています)。
任意の名前で新しいワークスペースを作成し、Fabric 容量を含むライセンスモード (“試用版”、Premium、または Fabric) を選択します。**
開いた新しいワークスペースは空のはずです。

イベントストリームを作成する

これで、ストリーミングソースからリアルタイムデータを検索して取り込む準備ができました。これを行うには、Fabric リアルタイムハブから開始します。

ヒント: 初めてリアルタイムハブを使用する場合は、はじめにのヒントが表示される場合があります。これらを閉じることができます。

左側のメニューバーで、リアルタイム ハブを選択します。

リアルタイムハブを使用すると、ストリーミングデータのソースを簡単に見つけて管理できます。
リアルタイムハブの接続先セクションで、[データソース] を選択します。
株式市場サンプルデータソースを見つけて、[接続] を選択します。次に、接続ウィザードで、ソースに stock という名前を付け、既定のイベントストリーム名を編集して stock-data に変更します。このデータに関連付けられている既定のストリームには、stock-data-stream という名前が自動的に付けられます。
[次へ] を選択し、ソースとイベントストリームが作成されるまで待ってから、[イベントストリームを開く] を選択します。イベントストリームには、デザインキャンバスに株式ソースと stock-data-stream が表示されます。

イベントハウスを作成する

イベントストリームはリアルタイムの株式データを取り込みますが、現時点では何もしません。キャプチャしたデータをテーブルに格納できるイベントハウスを作成しましょう。

左側のメニューバーで [ホーム] を選択し、リアルタイムインテリジェンスホームページで新しい Eventhouse を作成し、任意の一意の名前を付けます。

新しい空のイベントハウスが表示されるまで、表示されているヒントまたはプロンプトを閉じます。
左側のペインで、イベントハウスに Eventhouse と同じ名前の KQL データベースが含まれていることに注意してください。このデータベースでは、リアルタイムデータ用のテーブルを作成することも、必要に応じて追加のデータベースを作成することもできます。
データベースを選択し、関連付けられた queryset があることに注意してください。このファイルには、データベース内のテーブルのクエリを開始するために使用できる KQL クエリのサンプルがいくつか含まれています。

ただし、現時点ではクエリを実行するテーブルはありません。イベントストリームから新しいテーブルにデータを取得することで、この問題を解決しましょう。
KQL データベースのメインページで、 [データの取得] を選択します。
データソースで、[イベントストリーム]、[新しいイベントストリーム] を選択します。
[選択またはコピー先テーブルの作成] ウィンドウで、stock という名前の新しいテーブルを作成します。次に、[データソースの構成] ウィンドウで、ワークスペースと stock-data イベントストリームを選択し、接続 stock-data に名前を付けます。
[次へ] ボタンを使用して、データを検査し、構成を完了する手順を完了します。次に、構成ウィンドウを閉じて、イベントハウスと株式テーブルを表示します。

ストリームとテーブルの間の接続が作成されました。イベントストリームでそのことを確認しましょう。
左側のメニューバーで、[リアルタイム] ハブを選択し、[マイデータストリーム] ページを表示します。株式テーブルと stock-data-stream ストリームを一覧表示する必要があります。
stock-data-stream ストリームの […] メニューで、[イベントストリームを開く] を選択します。

イベントストリームにストリームの宛先が表示されるようになりました。

ヒント: デザインキャンバス上のコピー先を選択し、その下にデータプレビューが表示されない場合は、[更新する] を選択します。

この演習では、リアルタイムデータをキャプチャしてテーブルに読み込む非常にシンプルな Eventstream を作成しました。実際のソリューションでは、通常、一時的なウィンドウでデータを集計する変換を追加します (たとえば、5 分間にわたる各株式の平均価格をキャプチャする)。

次に、キャプチャしたデータに対してクエリを実行して分析する方法を見てみましょう。

キャプチャされたデータに対してクエリを実行する

Eventstream は、リアルタイムの株式市場のデータをキャプチャし、KQL データベースのテーブルに読み込みます。このテーブルに対してクエリを実行し、キャプチャされたデータを確認できます。

左側のメニューバーで、Eventhouse データベースを選択します。
データベースの queryset を選択します。
クエリペインで、次に示すように最初のクエリ例を変更します。
```
 stock
 | take 100
```
クエリコードを選択して実行し、テーブルの 100 行のデータを表示します。

結果を確認し、クエリを変更して、過去 5 分間の各株式コードの平均価格を取得します。

 stock
 | where ["time"] > ago(5m)
 | summarize avgPrice = avg(todecimal(bidPrice)) by symbol
 | project symbol, avgPrice

変更したクエリを強調表示し、クエリを実行して結果を表示します。
数秒待ってから、もう一度実行します。リアルタイムストリームから新しいデータがテーブルに追加されると、平均価格が変化することに注意します。

リアルタイムダッシュボードの作成

データのストリームによってデータが設定されるテーブルが作成されたので、リアルタイムダッシュボードを使用してデータを視覚化できます。

クエリエディターで、過去 5 分間の平均株価を取得するために使用した KQL クエリを選択します。
ツールバーで、[ダッシュボードにピン留めする] を選択します。次に、新しいダッシュボードで次の設定を使用してクエリをピン留めします。
- ダッシュボード名: Stock Dashboard
- タイル名: Average Prices
ダッシュボードを作成して開きます。次のようになります。
ダッシュボードの上部で、表示モードから編集モードに切り替えます。
平均価格タイルの編集アイコン (鉛筆アイコン) を選択します。
[ビジュアルの書式設定] ペインで、[ビジュアル] を [テーブル] から [縦棒グラフ] に変更します。
ダッシュボードの上部で、[変更の適用] を選択し、変更したダッシュボードを表示します。

これで、リアルタイムの株価データをライブで視覚化できるようになりました。

アラートを作成する

Microsoft Fabric のリアルタイムインテリジェンスには、リアルタイムイベントに基づいてアクションをトリガーできる Activator という名前のテクノロジが含まれています。これを使用して、平均株価が特定の金額で増加したときにアラートが生成されるようにしてみましょう。

株価の視覚化を含むダッシュボードウィンドウのツールバーで、[アラートの設定] を選択します。
[アラートの設定] ペインで、次の設定を使用してアラートを作成します。
- [クエリの実行間隔]: 5 分
- チェック: イベントのグループ化のたびに
- グループ化フィールド: 記号
- タイミング: avgPrice
- 条件: Increases by
- 値: 100
- アクション: メールを送信する
- 保存場所
  - ワークスペース: ワークスペース
  - 項目: 新しい項目を作成します
  - 新しい項目名: “任意の一意の名前
アラートを作成し、保存されるまで待ちます。次に、作成されたことを確認するペインを閉じます。
左側のメニューバーで、ワークスペースのページを選択します (メッセージが表示されたら、保存されていない変更をダッシュボードに保存します)。
ワークスペースページで、アラートのアクティベーターを含め、この演習で作成した項目を表示します。
アクティベーターを開き、そのページの avgPrice ノードで、アラートの一意識別子を選択します。次に、その履歴タブを表示します。

アラートがトリガーされていない場合があります。その場合、履歴にデータは含まれていません。平均株価が 100 を超えて変化した場合、アクティベーターからメールが送信され、アラートが履歴に記録されます。

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

この演習では、Eventhouse を作成し、Eventstream を使用してリアルタイムデータを取り込み、KQL データベーステーブルで取り込まれたデータのクエリを実行し、リアルタイムデータを視覚化するリアルタイムダッシュボードを作成し、アクティベーターを使用してアラートを構成しました。

Fabric のリアルタイムインテリジェンスの探索が終了したら、この演習用に作成したワークスペースを削除できます。

左側のバーで、ワークスペースのアイコンを選択します。
ツールバーで、[ワークスペース設定] を選択します。
[全般] セクションで、[このワークスペースの削除] を選択します。

Microsoft Fabric のリアルタイム インテリジェンスの使用を開始する