时间戳

首页 > 解决方案 > 使用服务总线触发器在 Azure 函数中自动转发消息

c# - 使用服务总线触发器在 Azure 函数中自动转发消息

问题描述

当我有自动转发队列时，Azure 功能无法启动：

函数 XXX 错误：函数“FunctionXXX”的侦听器无法启动。Microsoft.ServiceBus：无法在启用了自动转发的实体上创建消息接收器。

            // Code to create the queue:
            var manager = NamespaceManager.CreateFromConnectionString("ConnectionString");
            manager.CreateQueue(new QueueDescription("myqueue_done")
            {
                RequiresSession = false
            });
            manager.CreateQueue(new QueueDescription("myqueue")
            {
                ForwardTo = "myqueue_done",
                RequiresSession = false
            });

这是我的天蓝色功能：

    [FunctionName("FunctionXXX")]
    public static void Run([ServiceBusTrigger("myqueue", Connection = "AzureSbConnectionString")]string myQueueItem, string messageId, string CorrelationId, TraceWriter log)
    {          

        log.Info($"Message id={messageId}, CorrelationId={CorrelationId}, was processed: {myQueueItem}");
    }

真的有限制吗？有没有更好的方法在这个天蓝色函数沙箱方法中移动处理过的消息？

谢！

标签： c#azureazure-functionsazureservicebus

解决方案

这不是功能的限制，而是服务总线的工作方式。

启用自动转发后，服务总线会自动删除放置在第一个队列或订阅（源）中的消息，并将它们放入第二个队列或主题（目标）中。

如果您的消息被转发到另一个队列并从原始队列中删除，那么从同一队列创建手动接收器实际上没有意义。

推荐阅读