Azure Functions在Visual Studio中添加存储队列输出绑定参数的疑问

别担心，我来一步步教你给Http触发器函数加上队列输出绑定的参数，轻松实现向存储队列发送消息：

1. 直接在函数方法中添加队列输出绑定参数 #

你只需要在Run方法的参数列表里，添加带有[QueueOutput]属性的参数就行。下面是完整的函数签名示例：

[FunctionName("PublishMessage")]
public static IActionResult Run(
    [HttpTrigger(AuthorizationLevel.Anonymous, "get", "post", Route = null)] HttpRequest req,
    [QueueOutput("myqueue-items", Connection = "AzureWebJobsStorage")] out string queueMessage,
    ILogger log)

• QueueOutput的第一个参数是你的存储队列名称（如果队列不存在，Azure会自动帮你创建）
• Connection指定的是配置文件中存储连接字符串的键名，默认用AzureWebJobsStorage即可（本地调试时这个配置默认指向Azurite模拟存储）
• 参数类型用out string就能直接传递单条消息内容；如果需要批量发送，也可以换成ICollector<string>或者IAsyncCollector<string>

2. 配置本地调试的存储连接字符串 #

在项目里找到local.settings.json文件，确保里面有对应的存储连接字符串配置：

{
  "IsEncrypted": false,
  "Values": {
    "AzureWebJobsStorage": "UseDevelopmentStorage=true",
    "FUNCTIONS_WORKER_RUNTIME": "dotnet"
  }
}

"UseDevelopmentStorage=true"会自动指向本地的Azurite模拟器；如果你想用真实的Azure存储账户，把这个值换成你的存储账户连接字符串就行。

3. 在代码中使用绑定发送消息 #

在函数逻辑里给queueMessage赋值，就能自动把消息发送到队列了，比如：

log.LogInformation("C# HTTP trigger function processed a request.");

string requestBody = await new StreamReader(req.Body).ReadToEndAsync();
queueMessage = requestBody; // 把请求体内容作为消息发送到队列

return new OkObjectResult("Message sent to queue successfully!");

如果要批量发送，把out string换成ICollector<string>，调用Add()方法添加多条消息即可：

[QueueOutput("myqueue-items", Connection = "AzureWebJobsStorage")] ICollector<string> queueMessages,
// ...
queueMessages.Add("First message");
queueMessages.Add("Second message");

4. 部署到Azure后的配置 #

当你把函数部署到Azure后，记得在Azure门户的函数应用配置页面，确认AzureWebJobsStorage（或者你自定义的连接字符串键）已经设置为正确的Azure存储账户连接字符串。

内容的提问来源于stack exchange，提问作者fhnaseer