使用DaprBindingMessage发布Azure Service Bus定时消息时数据双重封装问题

问题根源 #

你错误地使用了DaprBindingMessage类型构造Dapr Pub/Sub事件。DaprBindingMessage是Dapr绑定（Bindings）组件专用类型，并非Pub/Sub场景的适配类型。当你把它作为DaprPubSubEvent的Data传入时，Dapr会将整个DaprBindingMessage序列化为JSON，最终导致Service Bus中的消息出现data字段嵌套的双重封装问题。

同时，Pub/Sub场景下设置Azure Service Bus的延迟投递，不能通过DaprBindingMessage的元数据实现，需要用Pub/Sub事件本身的元数据传递机制。

修正方案 #

直接传递业务消息内容，通过DaprPubSubEvent的Metadata属性设置ScheduledEnqueueTime，不再使用DaprBindingMessage。

修正后的代码 #

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 messageContent = "Test Message";
        
        // 设置Pub/Sub事件元数据，传递延迟投递时间（ISO 8601格式）
        var eventMetadata = new Dictionary<string, string>()
        {
            { "ScheduledEnqueueTime", DateTimeOffset.Now.AddMinutes(5).ToString("o") }
        };

        // 构造Pub/Sub事件，传入业务数据和元数据
        await pubEvent.AddAsync(new DaprPubSubEvent(messageContent)
        {
            Metadata = eventMetadata
        });

        return new OkObjectResult("TestResponse");
    }
}

关键说明 #

1. 消除双重封装：直接将业务消息作为DaprPubSubEvent的Data，Dapr会将其直接放入最终消息的data字段，不会额外嵌套data和metadata结构。
2. 延迟投递生效：Azure Service Bus的Dapr Pub/Sub组件支持通过元数据ScheduledEnqueueTime设置延迟投递，必须传入ISO 8601标准格式的时间字符串（用ToString("o")保证格式合规）。
3. 组件配置验证：确保你的Dapr Pub/Sub组件（testSub）配置为Azure Service Bus类型，且拥有正确的服务总线连接权限。

修正后，Service Bus队列中的消息结构会变为：

{
    "data": "Test Message",
    "datacontenttype": "application/json; charset=utf-8",
    "id": "xxx",
    "pubsubname": "testSub",
    "source": "ca",
    "specversion": "1.0",
    "time": "xxx",
    "topic": "testTopic",
    "traceid": "xxx",
    "traceparent": "xxx",
    "tracestate": "",
    "type": "com.dapr.event.sent"
}

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