Microsoft Power Automate 用の Azure Data Explorer コネクタ

[アーティクル]
11/19/2023

重要

このコネクタは、Microsoft Fabric のリアルタイム分析で使用できます。次の例外を含め、この記事の手順を使用します。

必要に応じて、「KQL データベースを作成する」の手順に従ってデータベースを作成します。
必要に応じて、「空のテーブルを作成する」の手順に従ってテーブルを作成します。
「コピー URI」の手順を使用して、クエリまたはインジェスト URI を取得します。
KQL クエリセットでクエリを実行します。

Power Automate (以前の Microsoft Flow) 用の Azure Data Explorer コネクタを使用すると、フローの調整とスケジュール設定や、通知とアラートの送信を、スケジュール設定されたタスクまたはトリガーされたタスクの一部として実行できます。

次のようにすることができます。

クエリ結果 (しきい値が特定の制限を超えた場合など) に基づいて通知とアラートを送信する。
テーブルやグラフが含まれるレポートを定期的 (毎日または毎週など) に送信する。
クラスターの管理コマンドを使用して、通常のジョブをスケジュールします。たとえば、.set-or-append コマンドを使用して、あるテーブルから別のテーブルにデータをコピーします。
Azure Data Explorer と他のデータベースの間でデータをエクスポートおよびインポートする。

詳細については、Azure Data Explorer Power Automate コネクタの使用例に関するページをご覧ください。

注意

コネクタがPower Automateネットワークで保護されたクラスターにアクセスするには、コネクタのリージョンに関連付けられている送信 IP アドレスをファイアウォール許可リストに追加する必要があります。詳細については、「Azure Data Explorer クラスターへのパブリックアクセスを管理する」を参照してください。

Azure Data Explorer コネクタを使用して新しいフローを作成する

このコネクタを使用するには、最初にトリガーを追加する必要があります。トリガーは、一定の期間に基づいて定義することも、直前のフローアクションへの応答として定義することも可能です。

Power Automate にサインインします。
新しいフローを作成するか、Power Automate ホームページで [マイフロー]>[+ 新規フロー] の順に選択します。
[Scheduled cloud flow](スケジュールされたクラウドフロー) を選択します。
[Scheduled cloud flow](スケジュールされたクラウドフロー) に、必要な情報を入力します。
[作成]>[新しいステップ] の順に選択します。
検索ボックスに「Kusto」または「Azure Data Explorer」と入力し、[Azure Data Explorer] を選択します。
リストからアクションを選択します。各アクションとその構成方法の詳細については、「フローアクション」を参照してください。

重要

フローを実行するには、有効な Azure Data Explorer の接続が必要です。接続の作成の詳細については、「で Azure Data Explorer接続Power Automateを作成する」を参照してください。

フローアクション

Azure Data Explorer コネクタを選択する際に、次のいずれかのアクションを選択してフローに追加できます。

KQL クエリの実行
KQL クエリの実行とグラフのレンダリング
非同期管理コマンドを実行する
管理コマンドを実行してグラフをレンダリングする
show management コマンドを実行する

このセクションでは、アクションごとに機能とパラメーターについて説明し、任意のフローにメールのアクションを追加する方法を示す例を挙げます。

KQL クエリの実行

注意

クエリがドットで始まる場合は、管理コマンドです。 [Run async management]$非同期管理の実行$ コマンドを使用します。

このアクションを使用して、指定したクラスターに対してクエリを実行します。この後に追加されるアクションは、クエリの結果の各行を反復処理します。

クエリの実行に 8 分以上かかる場合は、"RequestTimeout" 例外で失敗します。この問題を回避するには、クエリを最適化するか、小さな部分に分割します。詳細については、「クエリのベストプラクティス」を参照してください。

例

次のフローでは、1 分ごとにクエリがトリガーされます。このクエリでは、テーブル内のレコード数を検査し、レコード数が 0 よりも大きい場合に限ってメールを送信します。

KQL クエリの実行とグラフのレンダリング

注意

クエリがドットで始まる場合は、管理コマンドです。 [管理の実行] コマンドを使用してグラフをレンダリングします。

このアクションを使用して、KQL クエリの結果をテーブルまたはグラフとして視覚化します。たとえば、このフローを使用して、日次レポートをメールで受信します。

例

次のフローでは、クエリ結果がタイムグラフとして表示されます。

Azure Data Explorer コネクタのスクリーンショット。[KQL の実行] クエリとグラフのレンダリングアクションが表示されています。

非同期管理コマンドを実行する

管理コマンドを非同期的に実行するには、このアクションを使用します。これは、バックグラウンドで引き続き実行されることを意味します。アクションは、ID、状態、および状態を返します。非同期コマンドの状態と詳細をチェックするには、.show operations コマンドを使用し、このアクションによって返される ID を指定します。

非同期管理コマンドの実行に 60 分以上かかる場合は、"RequestTimeout" 例外で失敗します。

例

次のフローでは、非同期コマンドをトリガーして、'TransformedSysLogs' テーブルから 'TargetTable' に 10 個のレコードをコピーします。クエリには 'async' キーワード (keyword)が必要であることに注意してください。

$Azure Data Explorer コネクタのスクリーンショット。[Run async management command]$非同期管理コマンドの実行$ アクションが表示されています。$

管理コマンドを実行してグラフをレンダリングする

管理コマンドを実行し、結果をグラフとして表示するには、このアクションを使用します。グラフオプションには、HTML テーブル、円グラフ、タイムグラフ、横棒グラフが含まれます。

管理コマンドの実行に 8 分以上かかる場合は、"RequestTimeout" 例外で失敗します。

$[Run management]$管理の実行$ コマンドのスクリーンショット。繰り返しペインでグラフをレンダリングします。$

show management コマンドを実行する

このアクションは、show management コマンドを実行し、次のコネクタで使用できる結果を返します。

管理コマンドの実行に 8 分以上かかる場合は、"RequestTimeout" 例外で失敗します。

例

次のフローでは、.show 操作コマンドを実行し、非同期コマンド実行によって返される操作 ID を使用して非同期コマンドの状態を検索します。

Azure Data Explorer コネクタのスクリーンショット。[実行] [管理コマンドの実行] アクションが表示されています。

Kusto クエリの結果をメールで送信する

任意のフローにステップを含めて、レポートを、任意のメールアドレスにメールで送信できます。

新しいステップをフローに追加するには、 [+ 新規のステップ] を選択します。
検索ボックスに「Office 365」と入力し、 [Office 365 Outlook] を選択します。
[メールの送信 (V2)] を選択します。
レポートの送信先のメールアドレスを入力します。
メールの件名を入力します。
[コードビュー] . を選択します。
[本文] フィールドにカーソルをあわせ、 [動的コンテンツの追加] を選択します。
BodyHtmlを選択します。
[詳細オプションの表示]　を選択します。
[Attachments Name -1](添付ファイル名 - 1) で、 [Attachment Name](添付ファイル名) を選択します。
[Attachments Content](添付ファイルのコンテンツ) で、 [Attachment Content](添付ファイルのコンテンツ) を選択します。
必要に応じて、添付をさらに追加します。
必要に応じて、重要度レベルを設定します。
[保存] を選択します。

$[Attachments Name]$添付ファイル名$、[Attachments Content]$添付ファイルのコンテンツ$、および [保存] が強調表示されている、[電子メールの送信] ダイアログボックスのスクリーンショット。$

Azure Data Explorer 接続の作成

Azure Data Explorer コネクタが含まれるフローを実行するには、有効な Azure Data Explorer 接続を使用する必要があります。 Power Automate の左側のウィンドウから [データ]>[接続] を選択するか、フロー内から Azure Data Explorer コネクタのメニュー >[新しい接続の追加] を選択すると、新しい接続を作成して認証できます。

次のステップでは、フロー内から接続を作成する方法を示します。

[KQL クエリの実行] で、Power Automate コネクタの右上の 3 つのドットを選択します。
[新しい接続の追加] を選択します。初めて接続するときに、サインインして接続を認証するよう求めるプロンプトが表示されます。

認証

ユーザーの資格情報またはMicrosoft Entraアプリケーションを使用して認証できます。資格情報を使用して認証を行うには、[サインイン] を選択し、資格情報を入力します。

サービスプリンシパルを使用して認証を行うには、次のようにします。

[サービスプリンシパルを使用して接続する] を選択します。
フォームに次の情報を入力します。
- 接続名: 一見して意味の伝わる、新しい接続の名前。この例では、"MyApplication" を使用しました。
- クライアント ID: ご自身のアプリケーション ID。
- クライアントシークレット: ご自身のアプリケーションキー。
- テナント: アプリケーションを作成したMicrosoft Entra ディレクトリの ID。
注意

アプリケーションがMicrosoft Entra アプリケーションであり、クラスターでクエリを実行する権限があることを確認します。

認証が完了したら、新しい接続がフローで使用されていることを確認してください。

接続が設定されると、アプリケーションの資格情報を使用してフローが実行されます。

フローをテストする

フローが動作しているかを検査するには、次のようにフローの実行履歴を検査してください。

ホームページに移動しますPower Automate。
メインメニューから、[マイフロー] を選択します。
調べたいフローの行で [その他のコマンド] アイコンを選択し、 [実行履歴] を選択します。

実行されたすべてのフローの開始時刻、期間、および状態に関する情報が一覧表示されます。

フローの詳細については、 マイフロー で、調べたいフローを選択します。

実行が失敗した理由を確認するには、[実行の開始時刻] を選択します。フローが表示され、失敗したフローのステップが赤色の感嘆符で示されます。失敗したステップを展開し、詳細を表示します。右側の [詳細] ウィンドウにはエラー情報が示されています。この情報に基づいてトラブルシューティングを行うことができます。

エラーメッセージを示すフロー実行のスクリーンショット。

制限事項

要求あたりのレコードの最大数は 50,000 で、要求あたりの最大データサイズは 32 MB です。これらの制限は変更できません。
同期要求のタイムアウトは 8 分です。
非同期要求のタイムアウトは 60 分です。
コネクタは、getschema 演算子でサポートされていない演算子をサポートしていません。たとえば、fork、facet、evaluate の各演算子はサポートされていません。
Microsoft Edge または Google Chrome でのフローの動作をお勧めします。

Azure Kusto Logic App コネクタを使用して、スケジュールされたタスクまたはトリガーされたタスクの一部として Kusto クエリとコマンドを実行します。

Microsoft Power Automate 用の Azure Data Explorer コネクタ

Azure Data Explorer コネクタを使用して新しいフローを作成する