我如何从我的Azure函数向Azure服务总线发布消息？

Question

我的出发点是一个HTTP触发的Azure函数。它从请求正文中收集一些JSON，并将该消息传递给Azure服务总线。

我在这里一定遗漏了一些东西（我以前在RabbitMQ中使用过控制台应用程序），但是我如何从HTTP触发的Azure函数向服务总线发布消息。

我找到了几个关于配置function.json的参考资料（在Visual Studio中就是-im构建）。

**更新**仍然无法使其工作。得到了这段代码，但它以HTTP500失败。（它还说我需要查看OG-日志在哪里？）

public static class EI_WooCommerce_Hub
    {
        [FunctionName("EI_WooCommerce_Hub")]
        [return: ServiceBus("eilogging", Connection = "EIIntegrationServiceBusConnection")]
        public async static Task<string> Run([HttpTrigger(AuthorizationLevel.Function, "get", "post", Route = "EIWooCommerceHub/name/")]HttpRequestMessage req, TraceWriter log)
        {
            log.Info("Webhook triggered from: ");            
            return "Hello World to queue";
        }       
    }

**更新2**这似乎是配置问题。在function app上的应用程序设置中，我一直收到ServiceBus的授权错误。我用connectionstring添加了默认的“AzureWebJobsServiceBus”设置，然后它就工作了。由于某种原因，它无法拾取我自己的连接字符串。

Answer 1

您应该使用服务总线输出绑定。既然您提到了Visual Studio，那么我假设C#。最简单的示例如下所示：

[FunctionName("ServiceBusOutput")]
[return: ServiceBus("myqueue", Connection = "ServiceBusConnection")]
public static string ServiceBusOutput([HttpTrigger] dynamic input)
{
    return input.Text;
}

然后使用连接字符串将名为ServiceBusConnection的应用程序设置添加到具有队列MyQueue的命名空间（或在属性构造函数中重命名）。

您可以在Azure函数的Azure服务总线绑定-Output中找到更多信息。