如何实现Power BI数据集刷新失败触发Azure Logic App并获取详情？

前提准备 #

• 已配置Power BI刷新失败邮件通知（主题格式为Refresh Failed: {数据集名称} has failed to refresh）
• 已注册Azure AD应用，且该应用已在Power BI中获得数据集读取权限和工作区读取权限（需在Power BI管理门户的「应用权限」中配置）

步骤1：创建Logic App并配置邮件触发器 #

1. 在Azure门户创建新的「消耗型」或「标准型」Logic App
2. 添加触发器：选择Office 365 Outlook连接器的当收到新邮件(V3) 动作
   • 指定邮件监听文件夹（如「收件箱」）
   • 添加筛选规则：设置主题包含Refresh Failed:，确保仅响应刷新失败通知邮件
3. 添加「撰写」动作，提取数据集名称：
   • 使用以下表达式从邮件主题中解析名称：

     split(split(triggerBody()?['Subject'], ': ')[1], ' has failed')[0]
     

     （示例：主题为Refresh Failed: testdataset has failed to refresh时，返回结果为testdataset）

步骤2：获取Power BI API访问令牌 #

1. 添加「HTTP」动作，配置如下：
   • 请求方法：POST
   • URL：https://login.microsoftonline.com/{你的租户ID}/oauth2/v2.0/token
   • 请求头部：添加Content-Type = application/x-www-form-urlencoded
   • 请求正文（表单格式）：

     client_id={你的Azure应用ID}&scope=https://analysis.windows.net/powerbi/api/.default&client_secret={你的Azure应用密钥}&grant_type=client_credentials
     

2. 添加「解析JSON」动作，解析令牌返回结果，使用以下Schema：

   {
     "type": "object",
     "properties": {
       "token_type": {
         "type": "string"
       },
       "expires_in": {
         "type": "integer"
       },
       "ext_expires_in": {
         "type": "integer"
       },
       "access_token": {
         "type": "string"
       }
     }
   }
   

步骤3：根据数据集名称获取数据集ID #

1. 添加「HTTP」动作，调用Power BI数据集列表API：
   • 请求方法：GET
   • URL：数据集在指定工作区时用https://api.powerbi.com/v1.0/myorg/groups/{你的工作区ID}/datasets；在「我的工作区」时用https://api.powerbi.com/v1.0/myorg/datasets
   • 请求头部：添加Authorization = Bearer @body('解析_JSON')?['access_token']
2. 添加「筛选数组」动作，定位目标数据集：
   • 源数组：body('HTTP_获取数据集列表')?['value']
   • 筛选条件：item()?['name'] 等于 outputs('撰写')
3. 添加「撰写」动作，提取数据集ID：
   • 使用表达式：first(body('筛选数组'))?['id']

步骤4：获取刷新失败的详细错误信息 #

1. 添加「HTTP」动作，调用Power BI刷新历史API：
   • 请求方法：GET
   • URL：工作区数据集用https://api.powerbi.com/v1.0/myorg/groups/{你的工作区ID}/datasets/{outputs('撰写_数据集ID')}/refreshes?$top=1；我的工作区用https://api.powerbi.com/v1.0/myorg/datasets/{outputs('撰写_数据集ID')}/refreshes?$top=1
   • 请求头部：添加Authorization = Bearer @body('解析_JSON')?['access_token']
2. 添加「解析JSON」动作，解析刷新历史数据，重点提取：
   • status：确认是否为Failed
   • serviceExceptionJson：该字段包含数据源连接错误、查询错误等具体失败原因（需进一步解析此JSON字符串获取明细）

可选：结果推送与持久化 #

• 添加「发送邮件」「Teams消息」等动作，将数据集名称、ID、错误详情推送给相关人员
• 添加「SQL Server」「Azure Blob存储」等动作，将失败记录持久化存储

内容的提问来源于stack exchange，提问作者user2580179