使用Dapr发布定时Service Bus消息时遇dapr-app-id缺失错误

问题本质 #

1. 硬编码Sidecar端点无效：集群环境里，Dapr Sidecar的地址不能写死127.0.0.1:50002，得用Dapr自动注入的环境变量DAPR_GRPC_ENDPOINT或DAPR_HTTP_ENDPOINT来获取，硬写本地地址在集群里根本找不到Sidecar。
2. dapr-app-id配置错误：你传的someappid是随便写的，这个ID必须是当前Azure Function对应的Dapr应用ID——也就是部署时配置的dapr.io/app-id注解值，不是随便填的字符串。
3. 两种发布方式冲突：代码里同时用了Dapr输出绑定（[DaprPublish]）和DaprClient直接调用，没必要混用，容易出问题。

具体解决办法 #

办法1：用Dapr输出绑定（推荐） #

输出绑定会自动处理Sidecar通信和元数据，不用手动创建DaprClient，省心：

public static class TestFunc
{
    [FunctionName("TestFunc")]
    public static async Task<IActionResult> Run(
        [HttpTrigger(AuthorizationLevel.Anonymous, "get", "post", Route = "TestFunc")] HttpRequest req,
        [DaprPublish(PubSubName = "testSub", Topic = "testTopic")] IAsyncCollector<DaprPubSubEvent> pubEvent,            
        ILogger log)
    {
        log.LogInformation("HTTP trigger function processed a request.");
        
        var scheduledTime = DateTimeOffset.Now.AddMinutes(15);
        var pubSubEvent = new DaprPubSubEvent("Test Message")
        {
            Metadata = new Dictionary<string, string>
            {
                // 注意：Service Bus延迟投递的元数据键是*ScheduledEnqueueTimeUtc*，不是你之前写的ScheduledEnqueueTime
                { "ScheduledEnqueueTimeUtc", scheduledTime.UtcDateTime.ToString("o") }
            }
        };

        await pubEvent.AddAsync(pubSubEvent);
        return new OkResult();
    }
}

办法2：正确使用DaprClient #

如果非要用DaprClient，得修正端点和元数据：

public static class TestFunc
{
    [FunctionName("TestFunc")]
    public static async Task<IActionResult> Run(
        [HttpTrigger(AuthorizationLevel.Anonymous, "get", "post", Route = "TestFunc")] HttpRequest req,
        ILogger log)
    {
        log.LogInformation("HTTP trigger function processed a request.");
        
        string uData = "Test Message";
        // 不用硬编码端点，DaprClient会自动从环境变量读取Sidecar地址
        using var client = new DaprClientBuilder().Build();
        
        var metadata = new Dictionary<string, string>
        {
            { "ScheduledEnqueueTimeUtc", DateTimeOffset.Now.AddMinutes(15).UtcDateTime.ToString("o") },
            // 这里填当前Azure Function的Dapr应用ID，也就是部署时dapr.io/app-id的配置值
            { "dapr-app-id", "你的Azure Function对应的Dapr应用ID" }
        };

        await client.PublishEventAsync("testSub", "testTopic", uData, metadata);
        return new OkResult();
    }
}

同时要确保Azure Function的Dapr部署配置正确：

• 部署时加Dapr注解：dapr.io/app-id: 你的Azure Function对应的Dapr应用ID
• 集群里Dapr会自动给应用注入Sidecar的环境变量，不用手动配置

额外要检查的点 #

• 确认Dapr Pub/Sub组件testSub的配置文件里，Service Bus的连接字符串等参数都正确，而且组件已经部署到集群了。
• 检查Azure Function的服务账号有没有访问Dapr Sidecar和Service Bus的权限。

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