如何用C#调度PowerBI数据集刷新并接收完成通知？

因为通过Service Principal调用PowerBI REST API刷新数据集时，官方强制要求传入NoNotification参数，无法触发原生邮件通知，你可以通过以下几种C#实现方式自定义刷新完成的确认邮件：

方案1：轮询PowerBI刷新状态+自定义邮件发送 #

调用刷新API后，通过轮询刷新历史接口获取状态，当状态变为完成/失败时发送邮件。

核心步骤： #

1. 调用数据集刷新API时，保存返回的refreshId
2. 定期调用获取刷新历史的API，查询该refreshId对应的状态
3. 检测到状态为Completed或Failed时，触发邮件发送逻辑

C#代码示例： #

using System.Net.Http.Headers;
using MailKit.Net.Smtp;
using MimeKit;

// 1. 调用刷新API获取refreshId
var accessToken = "你的Service Principal获取的AccessToken";
var datasetId = "目标数据集ID";
var groupId = "工作区ID";

using var httpClient = new HttpClient();
httpClient.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", accessToken);

var refreshResponse = await httpClient.PostAsync(
    $"https://api.powerbi.com/v1.0/myorg/groups/{groupId}/datasets/{datasetId}/refreshes",
    new StringContent("{\"notifyOption\": \"NoNotification\"}", System.Text.Encoding.UTF8, "application/json")
);
var refreshResult = await refreshResponse.Content.ReadFromJsonAsync<RefreshResponse>();
var targetRefreshId = refreshResult.Id;

// 2. 轮询刷新状态
bool isRefreshCompleted = false;
RefreshStatus refreshStatus = null;
while (!isRefreshCompleted)
{
    var historyResponse = await httpClient.GetAsync(
        $"https://api.powerbi.com/v1.0/myorg/groups/{groupId}/datasets/{datasetId}/refreshes?$top=10"
    );
    var refreshHistory = await historyResponse.Content.ReadFromJsonAsync<List<RefreshStatus>>();
    refreshStatus = refreshHistory.FirstOrDefault(r => r.Id == targetRefreshId);

    if (refreshStatus != null && (refreshStatus.Status == "Completed" || refreshStatus.Status == "Failed"))
    {
        isRefreshCompleted = true;
        break;
    }

    // 等待5分钟后再查询，可根据实际刷新时长调整
    await Task.Delay(TimeSpan.FromMinutes(5));
}

// 3. 发送通知邮件
if (refreshStatus != null)
{
    var message = new MimeMessage();
    message.From.Add(new MailboxAddress("PowerBI刷新通知", "your-notify@example.com"));
    message.To.Add(new MailboxAddress("接收人", "recipient@example.com"));
    message.Subject = refreshStatus.Status == "Completed" ? "PowerBI数据集刷新完成" : "PowerBI数据集刷新失败";
    message.Body = new TextPart("plain")
    {
        Text = $"数据集{datasetId}刷新状态：{refreshStatus.Status}\n开始时间：{refreshStatus.StartTime}\n结束时间：{refreshStatus.EndTime}"
    };

    using var client = new SmtpClient();
    await client.ConnectAsync("smtp.example.com", 587, false);
    await client.AuthenticateAsync("smtp-username", "smtp-password");
    await client.SendAsync(message);
    await client.DisconnectAsync(true);
}

// 辅助模型类
public class RefreshResponse { public Guid Id { get; set; } }
public class RefreshStatus
{
    public Guid Id { get; set; }
    public string Status { get; set; }
    public DateTime StartTime { get; set; }
    public DateTime? EndTime { get; set; }
}

注意事项： #

• 需添加API调用异常处理，避免无限循环
• 推荐使用MailKit替代SmtpClient（后者在.NET Core/.NET 5+中已标记为过时）
• 可根据数据集平均刷新时长调整轮询间隔

方案2：使用PowerBI Webhook接收刷新事件 #

配置PowerBI Webhook监听数据集刷新事件，当事件触发时，C#后端接口接收通知并发送邮件。

核心步骤： #

1. 在PowerBI中为目标数据集创建Webhook，指定你的C#后端接口URL
2. C#端实现POST接口，接收PowerBI推送的事件 payload
3. 解析事件中的刷新状态，触发邮件发送逻辑

C#接口示例（ASP.NET Core）： #

[ApiController]
[Route("api/powerbi/webhook")]
public class PowerBIWebhookController : ControllerBase
{
    [HttpPost]
    public async Task<IActionResult> ReceiveWebhook([FromBody] PowerBIWebhookEvent payload)
    {
        // 可选：验证Webhook签名，防止伪造请求
        // var signature = Request.Headers["X-PowerBI-Signature"].FirstOrDefault();
        // 签名验证逻辑...

        if (payload.EventType == "DatasetRefreshCompleted" || payload.EventType == "DatasetRefreshFailed")
        {
            await SendRefreshNotificationEmail(payload.DatasetId, payload.EventType);
        }

        return Ok();
    }

    private async Task SendRefreshNotificationEmail(string datasetId, string eventType)
    {
        // 复用方案1中的邮件发送逻辑
    }
}

// 辅助模型类
public class PowerBIWebhookEvent
{
    public string EventType { get; set; }
    public string DatasetId { get; set; }
    // 可根据需求添加其他事件字段
}

注意事项： #

• Webhook需要公网可访问的接口地址，本地开发可使用ngrok等工具做端口穿透
• 必须配置签名验证，确保请求来自PowerBI官方

方案3：Azure Function + PowerBI触发器（云环境推荐） #

如果系统部署在Azure上，可利用Azure原生集成实现无轮询的通知：

1. 创建Azure Function，选择PowerBI Dataset Refresh Completed触发器
2. 在Function中编写C#代码，触发时执行邮件发送逻辑
3. 配置触发器关联目标PowerBI工作区和数据集

这种方式无需手动维护轮询逻辑，适合云环境下的生产场景。

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