适用于 Microsoft Power Automate 的 Azure 资源管理器连接器

重要

此连接器可用于 Microsoft Fabric 中的实时智能。 使用本文中的说明时，请注意以下例外情况：

• 如果需要，请按照创建 KQL 数据库中的说明创建数据库。
• 如果需要，请按照创建空表中的说明创建表。
• 使用复制 URI 中的说明获取查询或引入 URI。
• 运行 KQL 查询集中的查询。

通过 Power Automate（以前称为 Microsoft Flow）的 Azure 数据资源管理器连接器，可以作为计划式或触发式任务的一部分来编排和计划流、发送通知和警报。

您可以：

• 根据查询结果发送通知和警报，例如阈值超过特定限制时。
• 定期（如每日或每周）发送包含表和图表的报表。
• 通过对群集使用管理命令来计划常规作业。 例如，使用 .set-or-append 命令将数据从一个表复制到另一个表。
• 在 Azure 数据资源管理器与其他数据库之间导出和导入数据。

有关详细信息，请参阅 Azure 数据资源管理器 Power Automate 连接器用法示例。

注意

为了使 Power Automate 连接器能够访问受网络保护的群集，必须将与连接器的区域关联的出站 IP 地址添加到防火墙允许列表。 有关详细信息，请参阅管理对 Azure 数据资源管理器群集的公共访问。

使用 Azure 数据资源管理器连接器创建新流

若要使用此连接器，必须首先添加一个触发器。 可以定义基于重复时间段的触发器，也可以将触发器定义为对前一流操作的响应。

1. 登录到 Power Automate。

2. 创建新流，或者在 Power Automate 主页中选择“我的流”>“+ 新建流”。

   

3. 选择“计划云端流”。

   

4. 在“生成计划云端流”中输入所需信息。

   

5. 选择“创建”>“+ 新建步骤”。

6. 在搜索框中输入“Kusto”或“Azure 数据资源管理器”，然后选择“Azure 数据资源管理器”。

   

7. 从列表中选择操作。 有关每个操作以及如何进行配置的说明，请参阅流操作。

   重要

   必须具有有效的 Azure 数据资源管理器连接才能让流运行。 有关创建连接的信息，请参阅在 Power Automate 中创建 Azure 数据资源管理器连接。

   

流操作

选择 Azure 数据资源管理器连接器时，可以选择以下操作之一以添加到流：

• 运行 KQL 查询
• 运行 KQL 查询并呈现图表
• 运行异步管理命令
• 运行控制命令并呈现图表
• 运行显示管理命令

本节介绍每个操作的功能和参数，并提供一个示例以说明如何将电子邮件操作添加到任何流中。

运行 KQL 查询

注意

如果查询以点开头，则它是管理命令。 使用运行异步管理命令。

使用此操作会查询指定群集。 之后添加的操作会循环访问查询结果的每一行。

如果查询运行时间超过 8 分钟，则会失败并显示“RequestTimeout”异常。 若要防止出现此问题，请优化查询或将其划分为较小的部分。 有关详细信息，请参阅查询最佳做法。

示例

下面的流每分钟触发一次查询。 该查询检查表中的记录数，仅当记录数大于 0 时才发送电子邮件。

运行 KQL 查询并呈现图表

注意

如果查询以点开头，则它是管理命令。 使用运行控制命令并呈现图表。

使用此操作可将 KQL 查询结果直观呈现为表或图表。 例如，使用此流可通过电子邮件接收每日报告。

如果查询运行时间超过 8 分钟，则会失败并显示“RequestTimeout”异常。 若要防止出现此问题，请优化查询或将其划分为较小的部分。 有关详细信息，请参阅查询最佳做法。

示例

下面的流将查询结果显示为时间图。

运行异步管理命令

使用此操作可以异步运行管理命令，这意味着它将在后台继续运行。 该操作返回 ID、状况和状态。 若要检查异步命令的状态和详细信息，请使用 .show 操作命令以及此操作返回的 ID。

如果异步管理命令运行时间超过 60 分钟，则会失败并显示“RequestTimeout”异常。

示例

下面的流将触发一条异步命令，将 10 条记录从“TransformedSysLogs”表复制到“TargetTable”。 请注意，查询中需要“async”关键字。

运行控制命令并呈现图表

使用此操作运行管理命令，并将结果显示为图表。 图表选项包括 HTML 表、饼图、时间图表和条形图。

如果管理命令运行时间超过 8 分钟，则会失败并显示“RequestTimeout”异常。

运行显示管理命令

此操作运行显示管理命令并返回可在以下连接器中使用的结果。

如果管理命令运行时间超过 8 分钟，则会失败并显示“RequestTimeout”异常。

示例

下面的流运行 .show operation 命令，以使用异步命令执行返回的操作 ID 来查找异步命令的状态。

通过电子邮件发送 Kusto 查询结果

可以在任何流中包含一个步骤，以通过电子邮件将报告发送到任何电子邮件地址。

1. 选择“+ 新建步骤”以在流中添加新步骤。
2. 在搜索框中输入“Office 365”，然后选择“Office 365 Outlook”。
3. 选择发送电子邮件 (V2)。
4. 输入要将电子邮件报告发送到的电子邮件地址。
5. 输入电子邮件的主题。
6. 选择“代码视图”。
7. 将光标置于“正文”字段中，然后选择“添加动态内容”。
8. 选择“BodyHtml”。
9. 选择“显示高级选项”。
10. 在“附件名称 - 1”下，选择“附件名称”。
11. 在“附件内容”下，选择“附件内容”。
12. 可根据需要添加更多附件。
13. 可根据需要设置重要性级别。
14. 选择“保存”。

创建 Azure 数据资源管理器连接

若要运行包含 Azure 数据资源管理器连接器的流，必须使用有效的 Azure 数据资源管理器连接。 若要创建新连接并进行身份验证，可以从 Power Automate 的左侧窗格中选择“数据”>“连接”，或者从流中，选择 Azure 数据资源管理器连接器的“添加新连接”菜单。

以下步骤演示如何从流中创建连接。

1. 在“运行 KQL 查询”中，选择 Power Automate 连接器右上角的三个点。

   

2. 选择“添加新连接”。 首次连接时，系统会提示你登录以对连接进行身份验证。

   

身份验证

可以使用用户凭据或 Microsoft Entra 应用程序进行身份验证。 若要使用凭据进行身份验证，请选择“登录”，然后输入凭据。

若要使用服务主体进行身份验证：

1. 选择“通过服务主体进行连接”。

2. 使用以下信息填写窗体：

   • 连接名称：新连接的名称，具有描述性且有意义。 在此示例中，我们使用了“MyApplication”。
   • 客户端 ID：你的应用程序 ID。
   • 客户端机密：你的应用程序密钥。
   • 租户：在其中创建了该应用程序的 Microsoft Entra 目录的 ID。

   注意

   确保你的应用程序是 Microsoft Entra 应用程序并有权在群集上运行查询。

   

   身份验证完成后，验证你的流程是否在使用新连接。

   

   设置连接后，流将使用应用程序凭据运行。

测试流

若要检查流是否在运行，请查看流的运行历史记录：

1. 转到 Power Automate 主页。

2. 在主菜单中，选择“我的流”。

   

3. 在要调查的流的行上，选择“更多命令”图标，然后选择“运行历史记录”。

   

   此时会列出所有流运行，以及有关开始时间、持续时间和状态的信息。

   若要查看有关流的完整详细信息，请在“我的流”中选择要调查的流。

   

若要查看运行失败的原因，请选择运行开始时间。 此时会显示该流，失败的流步骤以红色感叹号指示。 展开失败的步骤以查看其详细信息。 右侧的“详细信息”窗格包含有关失败的信息，使你可以对其进行故障排除。

限制

• 每个请求的最大记录数为 50,000，每个请求的最大数据大小为 32 MB。 无法更改这些限制。
• 同步请求的超时时间为 8 分钟。
• 异步请求的超时时间为 60 分钟。
• 连接器不支持 getschema 运算符所不支持的运算符。 例如，不支持 fork、facet 和 evaluate 运算符。
• 流最适合在 Microsoft Edge 和 Google Chrome 上运行。

相关内容

• 使用 Azure Kusto 逻辑应用连接器来运行 Kusto 查询和命令，这是计划或触发任务的一部分。