使用Dapr发布带元数据的消息：元数据去向何方？

问题原因 #

你传递给PublishEventAsync的metaData参数是Dapr API层面的元数据，并非CloudEvent的属性，因此不会自动注入到接收端的CloudEvent对象中。Dapr默认只会将这部分元数据用于内部处理（比如队列配置），不会映射到CloudEvent的自定义属性里。

解决方案 #

有两种可行的方式将自定义元数据传递到接收端的CloudEvent中：

方法1：直接构建CloudEvent对象发布 #

手动创建CloudEvent实例，将消息数据和自定义属性直接绑定到对象上，再通过Dapr客户端发布：

public class Message
{
    [JsonPropertyName("messageId")]
    public Int32 MessageId { get; set; }

    [JsonPropertyName("tenantId")]
    public Int32 TenantId { get; set; }

    public Message(int messageId, int tenantId)
    {
        MessageId = messageId;
        TenantId = tenantId;
    }
}

using var client = new DaprClientBuilder().Build();
var tenantId = Rnd.Next(0, _test.DifferentTenantIds)+1;

// 构建包含自定义属性的CloudEvent
var cloudEvent = new CloudEvent(
    source: "your-app-id", // 替换为你的实际应用ID
    type: "com.yourdomain.event1" // 遵循CloudEvent规范的事件类型格式
)
{
    Data = new Message(1, tenantId),
    DataContentType = new ContentType("application/json")
};
// 添加自定义SessionId属性（建议用小写符合CloudEvent规范）
cloudEvent.SetAttribute("sessionid", $"TENANT.{tenantId}");

// 发布CloudEvent
var status = await client.PublishEventAsync("PRODUCT", "EVENT1", cloudEvent, CancellationToken.None);

接收端代码只需确保属性名匹配：

app.MapPost("/productEvent1", async ([FromBody] CloudEvent job, [FromServices] ILogger<ProductManagementApi> logger) =>
{
    var sessionId = job.GetAttribute("sessionid");
    logger.LogInformation($"* received a message A with sessionId={sessionId}");
    return Results.Ok();
});

方法2：使用cloudevent-前缀的元数据 #

如果不想手动构建CloudEvent，可以在发布时给元数据键加上cloudevent-前缀，Dapr会自动将这些键转换为CloudEvent的属性（去掉前缀）：

using var client = new DaprClientBuilder().Build();
var tenantId = Rnd.Next(0, _test.DifferentTenantIds)+1;

// 给自定义元数据添加cloudevent-前缀
var metaData = new Dictionary<string, string>()
{
    { "cloudevent-sessionid", $"TENANT.{tenantId}" }
};
var message = new Message(1, tenantId);

// 发布消息，Dapr会自动将前缀后的键映射为CloudEvent属性
var status = await client.PublishEventAsync("PRODUCT", "EVENT1", message, metaData, CancellationToken.None);

接收端同样用job.GetAttribute("sessionid")获取属性值即可。

注意事项 #

• CloudEvent规范建议属性名使用小写字母（可包含连字符），避免大小写不匹配问题；
• 确保Dapr版本为1.4及以上，该版本开始支持上述元数据映射特性；
• Redis作为消息队列时，Dapr会自动处理CloudEvent的序列化与传递，无需额外配置队列本身。

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