azure - 来自 Azure Function 的 Azure 队列/主题消息的自定义消息属性

Question

当我将队列/主题消息放入 Azure 函数的队列中时，我希望能够将自定义属性添加到队列/主题消息中。自定义属性用于将消息过滤到不同的主题中。我一定错过了一些东西，因为这个工作示例似乎没有任何地方可以放置自定义属性。

public static async Task<HttpResponseMessage> Run(HttpRequestMessage req, 
                            TraceWriter log,
                            ICollector<Contact> outputSbMsg)

    {
        var contactList = await req.Content.ReadAsAsync<ContactList>();

        foreach(var contact in contactList.Contacts)
        {
            if (contact.ContactId == -1)
            {
                continue;
            }

            contact.State = contactList.State;

            outputSbMsg.Add(contact);
        }
    }

我正在通过 Azure 门户编写该函数。联系人列表通过 http 请求正文进入该函数。这些函数解析每个联系人，添加修改一些属性并将每个联系人提交到队列主题。此外，我从请求 header 和联系人列表中提取其他数据，并且我想在队列主题中使用该数据将请求过滤到不同的订阅中。

编辑:

根据下面 @Sean Feldman 的建议，在将 BrokeredMessage 添加到输出集合之前，将数据添加到 BrokeredMessage 中。关键部分是在将联系人对象添加到 BrokeredMessage 之前对其进行序列化。

 public static async Task<HttpResponseMessage> Run(HttpRequestMessage req, 
                                TraceWriter log,
                                ICollector<BrokeredMessage> outputSbMsg)

        {
            var contactList = await req.Content.ReadAsAsync<ContactList>();

            foreach(var contact in contactList.Contacts)
            {
                if (contact.ContactId == -1)
                {
                    continue;
                }

                string jsonData = JsonConvert.SerializeObject(contact);

                BrokeredMessage message = new BrokeredMessage(jsonData);

                message.Properties.Add("State", contactList.State);

                outputSbMsg.Add(message);
            }
        }

谢谢

Answer 1

能够设置custom/user properties ，输出收集器应属于 native Azure 服务总线消息类型 BrokeredMessage .

就您而言，您必须更改 ICollector<Contact>至ICollector<BrokeredMessage> .