Azure 函数不向服务总线发布消息

Question

我创建了一个通过 Http 触发的函数应用程序。函数应用应向 Azure 服务总线主题发布消息。由于某些原因，我没有在主题中发布任何消息。我成功触发了函数应用程序。我不确定我在这里做错了什么。下面是我的代码。

     [FunctionName("MessageProcessorFunction")]
            [return: ServiceBus("mytopic", Connection = "Endpoint=sb://abcsb.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=wBCZ4ssssssohbg1ZUYKw4q8cpKaoZLIG9NR28ZoUDhBG8=")]
            public async Task<string> Run(
               [HttpTrigger(AuthorizationLevel.Function, "post", Route = "sms")] HttpRequest req,
               ILogger log)
            {
                log.LogInformation("HTTP trigger function processed a request.");

                return "hello World";
            }

但是，下面的控制台应用成功地向服务总线主题发布了一条消息。这是代码

    TopicClient _topicClient = new TopicClient("Endpoint=sb://abcsb.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=wBCZ4ssssssohbg1ZUYKw4q8cpKaoZLIG9NR28ZoUDhBG8=", "whispir");
                string data = JsonConvert.SerializeObject("Hello world");
                Message message = new Message(Encoding.UTF8.GetBytes(data));

                try
                {
                    await _topicClient.SendAsync(message);
                }
                catch (Exception e)
                {
                    Console.WriteLine(e.Message);
                }

local.settings.json

"IsEncrypted": false,
    "Values": {
        "AzureWebJobsStorage": "UseDevelopmentStorage=true",
        "FUNCTIONS_WORKER_RUNTIME": "dotnet",
        "ServiceBusConnectionString": "Endpoint=sb://abcsb.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=wBCZ4okoohbg1ZUYKw4q8cpKaoZLIG9NR28ZoUDhBG8="

}

有什么想法吗？

-艾伦-

Answer 1

Connection 属性应该收到一个设置键，而不是实际的连接字符串。

如果您想在本地尝试，您必须更改 local.settings.json 文件并将连接字符串添加到特定键：

{
  "Values": {
    "ServiceBusConnectionString": "Endpoint=sb://abcsb.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=wBCZ4ssssssohbg1ZUYKw4q8cpKaoZLIG9NR28ZoUDhBG8="
  }
}

然后，像这样在您的函数中使用它：

[FunctionName("MessageProcessorFunction")]
[return: ServiceBus("mytopic", Connection = "ServiceBusConnectionString")]
public async Task<string> Run(
    [HttpTrigger(AuthorizationLevel.Function, "post", Route = "sms")] HttpRequest req,
    ILogger log)
{
    log.LogInformation("HTTP trigger function processed a request.");

    return "hello World";
}

应该可以。
如果没有，请告诉我。 :)

Azure 函数不向服务总线发布消息

Azure Function Not Publishing Message to Service Bus

c#

azure

azureservicebus

.net-core

azure-functions

local.settings.json