我们如何向消息添加属性?
how do we add properties to a message?
是否可以在进行绑定时设置消息属性(我认为它们称为 UserProperties)?
在我的函数中,我正在对服务总线进行输出绑定:
[return: ServiceBus("%Detach:Done%", Connection = "Detach:ServiceBus", EntityType = EntityType.Topic)]
我们绑定ServiceBus时如何设置消息属性?
在异步函数中,使用 return 值或 IAsyncCollector
而不是 out
参数。对于 2.x,使用 Message 而不是像 IAsyncCollector<Message>
.
这样的 BrokeredMessage
然后您可以在消息上设置MessageId
属性。参考这个.
var message = new Message() { MessageId = messageId};
public static class Function7
{
[FunctionName("Function7")]
[return: ServiceBus("test2",
Connection = "AzureServiceBusConnectionString", EntityType = EntityType.Queue)]
public static async Task<Message> Run([ServiceBusTrigger("test",
Connection = "AzureServiceBusConnectionString")]string myQueueItem, ILogger log)
{
log.LogInformation(
$"C# ServiceBus queue trigger function processed message: {myQueueItem}");
var message = new Message(Encoding.UTF8.GetBytes("{}"));
message.Label = "Hello";
message.UserProperties.Add("abc", 123);
return await Task.FromResult<Message>(message);
}
}
是否可以在进行绑定时设置消息属性(我认为它们称为 UserProperties)?
在我的函数中,我正在对服务总线进行输出绑定:
[return: ServiceBus("%Detach:Done%", Connection = "Detach:ServiceBus", EntityType = EntityType.Topic)]
我们绑定ServiceBus时如何设置消息属性?
在异步函数中,使用 return 值或 IAsyncCollector
而不是 out
参数。对于 2.x,使用 Message 而不是像 IAsyncCollector<Message>
.
然后您可以在消息上设置MessageId
属性。参考这个
var message = new Message() { MessageId = messageId};
public static class Function7
{
[FunctionName("Function7")]
[return: ServiceBus("test2",
Connection = "AzureServiceBusConnectionString", EntityType = EntityType.Queue)]
public static async Task<Message> Run([ServiceBusTrigger("test",
Connection = "AzureServiceBusConnectionString")]string myQueueItem, ILogger log)
{
log.LogInformation(
$"C# ServiceBus queue trigger function processed message: {myQueueItem}");
var message = new Message(Encoding.UTF8.GetBytes("{}"));
message.Label = "Hello";
message.UserProperties.Add("abc", 123);
return await Task.FromResult<Message>(message);
}
}