Logic Apps と Power Automate を使用して Eventstream にイベントをストリーム配信する

2025-01-31

このチュートリアルでは、Microsoft Fabric Eventstream のカスタムエンドポイントソースを使用して、Logic Apps または Power Automate から Real-Time Intelligence にリアルタイムイベントをストリーミングする方法について学びます。 Logic Apps と Power Automate のフローの構成は異なりますが、同じ目的を果たします。ScanUtcTime や FlightInfoなどの列を含むシミュレートされたフライトデータを定期的に送信します。フローの違いは、Logic Apps では JavaScript の実行がサポートされていますが、Power Automate サポートされていないためです。

ロジックアプリ (ステートフルワークフローを使用) と Power Automate のフローは次のとおりです。

Logic Apps フロー:
Power Automate フロー:

Logic Apps のと Power Automate のフローは異なりますが、同じ結果を得て、フライトデータを Real-Time インテリジェンスに送信します。 要件に最も適したアプローチを選択します。

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

イベントストリームを作成し、カスタムエンドポイントソースを追加します。
Event Hubs エンドポイントの詳細の取得。
カスタムエンドポイント経由で Logic Apps をイベントストリームに接続する。
カスタムエンドポイント経由で Power Automate をイベントストリームに接続する。
eventstream のデータをプレビューします。

前提条件

開始する前に、次の前提条件を満たす必要があります。

Eventstream が配置されている共同作成者以上のアクセス許可を持つワークスペースへのアクセス。
Logic Appsの場合、ロジックアプリを作成するための有効なサブスクリプションを持つ Azure アカウント。お持ちでない場合は、無料の Azure アカウントにサインアップ。
Power Automate の場合、アクティブな Power Automate アカウントです。

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

Fabric ポータルに移動します。
左側のナビゲーションバー [マイワークスペース] を選択します。
[マイワークスペース ] ページで、コマンドバーの [+ 新しい項目を選択します。
[新しい項目] ページで [Eventstream] を検索し、[Eventstream] を選択します。
[新しいイベントストリーム] ウィンドウで、イベントストリームの [名前] を入力し、[作成] を選択します。
ワークスペースで新しいイベントストリームを作成するには、数秒かかることがあります。イベントストリームが作成されると、メインエディターが表示されます。メインエディターでは、イベントストリームへのソースの追加から始めることができます。

カスタムエンドポイントソースを追加する

カスタムエンドポイントソースを追加するには、開始ページで、「カスタムエンドポイントを使用」を選択します。
[カスタムエンドポイント] ダイアログで、[ソース名] にカスタムソースの名前を入力し、[追加] を選択します。
カスタムエンドポイントソースを作成すると、編集モードでキャンバス上の eventstream に追加されます。新しく追加されたデータをカスタムアプリソースから実装するには、公開を選択します。

カスタムエンドポイントを使用して Logic Apps からイベントストリームにイベントをストリーム配信する

このセクションでは、定期的なスケジュールでシミュレートされたフライトデータを定期的に生成するワークフローを設計する方法について説明します。ワークフローでは、"JavaScript の実行" アクションで JavaScript コードを使用して、各フィールドのランダム化された値を含むフライト情報メッセージを作成します。メッセージが構築されると、Event Hub プロトコルを使用して eventstream のエンドポイントに送信されます。

従量課金プランの "JavaScript の実行" アクションには追加の統合アカウントが必要です。従量課金プランの代わりに、Standard プランを使用してロジックアプリを作成し、構成を簡略化します。
ワークフローを作成します。ワークフローを作成する際には、「繰り返し」トリガー（このチュートリアルで必要）はステートレストリガーの一覧にはないため、ステートフルの 状態タイプを選択してください。
新しく作成したワークフローを開き、[トリガー追加] を選択し、[繰り返し] を選択します。
定期実行のために の繰り返し を設定します。これにより、設定した間隔に基づいて、フロー全体が周期的にトリガーされます。
[+ アクションの追加] を選択してから、[JavaScript の実行] を選択します。
このスクリプトコンテンツコード フィールドにコピーします。
[+ アクションの追加] を選択し、[Event Hubs] アクションステップを追加してから、[イベントの送信] を選択します。
新しい接続を作成し、接続名入力します。
Eventstream カスタムエンドポイントからコピーできる接続文字列を入力し、[新しい作成] を選択して接続を作成します。
新しい接続が作成され、イベントハブのパラメーター構成に戻ったら、イベントハブ名のドロップダウンメニューから [カスタム値の入力] を選択し、Eventstream カスタムエンドポイントからコピーできるイベントハブ名を入力します。
詳細パラメーターコンテンツ を選択し、出力として コンテンツ を構成します。
[保存] を選択してワークフローを保存します。
デザイナーのツールバーで、[実行] メニューから [を実行] を選択します。
これらの手順を完了したら、ロジックアプリワークフローからのイベントストリーム内のデータをプレビューできます。

カスタムエンドポイントを使用して Power Automate からイベントストリームにイベントをストリーミングする

このセクションでは、Power Automate でフローを作成してシミュレートされたフライトデータを生成し、それをイベントストリームに送信する方法について説明します。 Power Automate では "JavaScript コードの実行" アクションがサポートされていないため、シミュレートされたデータを生成するには、いくつかの変数を定義する必要があります。このプロセスを簡略化するために、ダウンロードとインポートに必要な変数を含む事前構成済みフローが提供されます。事前構成済みパッケージを使用してフローを作成し、残りの構成を完了して、シミュレートされたデータを eventstream に送信するには、次の手順に従います。

モックフライトデータの送信をスケジュールするための事前構成済みのフローが含まれている、この git リポジトリからこの zip ファイルをダウンロードします。
Power BI アカウントを使用 Power Automate にログインします。
左側のナビゲーションウィンドウ [マイフロー] に移動します。
[インポート] ボタンをクリックした後で、[パッケージのインポート (レガシ)] を選択します。
手順 1からダウンロードした zip ファイル選択し、アップロードします。
[更新] を選択して [インポートの設定] を [新しく作成する] に変更してから、[保存] を選択します。
次 インポート を選択して、このパッケージを独自のフローにインポートします。
マイフローに戻ると、新しく追加された Power Automate フローが表示されます。
Power Automate フローを開き、[ 編集] を選択し、Event Hubs アクションステップを追加して、[イベント送信] を選択します。 Logic Apps のストリームイベントのステップを参照してイベントハブを構成し、長時間実行のために [繰り返し] を設定します。
[マイフロー] に戻り、フローを選択して、[オンにする] を選択します。
これらの手順を完了すると、Power Automate ワークフローの eventstream 内のデータをプレビューできます。