如何在Azure函数中无需队列触发器读取Azure队列数据

没有像ICollector<T>那样直接通过参数注入的队列读取器，但可以借助Azure Storage SDK直接操作队列，实现定时批量读取的需求，具体步骤如下：

• 安装依赖包：确保你的函数项目已安装Azure.Storage.Queues NuGet包
• 初始化队列客户端：可以通过依赖注入或直接用存储连接字符串创建QueueClient实例
• 批量读取并处理消息：调用ReceiveMessagesAsync批量拉取消息，处理完成后删除消息

代码示例（隔离进程模型） #

using Azure.Storage.Queues;
using Azure.Storage.Queues.Models;
using Microsoft.Azure.Functions.Worker;
using Microsoft.Extensions.Logging;
using System.Text.Json;

public class QueueBatchProcessor
{
    private readonly QueueClient _queueClient;

    // 推荐通过依赖注入获取QueueClient
    public QueueBatchProcessor(QueueClient queueClient)
    {
        _queueClient = queueClient;
    }

    [Function("QueueBatchProcessor")]
    public async Task RunAsync([TimerTrigger("0 */5 * * * *")] TimerInfo myTimer, ILogger log)
    {
        log.LogInformation($"开始批量处理队列消息：{DateTime.Now}");

        // 单次最多读取32条（Azure队列的单次读取上限），设置5分钟可见性超时避免重复读取
        var messageResult = await _queueClient.ReceiveMessagesAsync(maxMessages: 32, visibilityTimeout: TimeSpan.FromMinutes(5));

        foreach (QueueMessage message in messageResult.Value)
        {
            // 反序列化消息内容
            var myType = JsonSerializer.Deserialize<MyType>(message.Body.ToString());
            
            // 这里替换为你的业务处理逻辑
            log.LogInformation($"处理消息：{myType.Id}");

            // 处理完成后删除消息，否则超时后消息会重回队列
            await _queueClient.DeleteMessageAsync(message.MessageId, message.PopReceipt);
        }

        log.LogInformation($"批量处理完成：{DateTime.Now}");
    }
}

依赖注入配置（Program.cs） #

using Azure.Storage.Queues;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Hosting;

var host = new HostBuilder()
    .ConfigureFunctionsWorkerDefaults()
    .ConfigureServices(services =>
    {
        string connectionString = Environment.GetEnvironmentVariable("AzureWebJobsStorage")!;
        string queueName = "myQueue";
        
        services.AddSingleton(new QueueClient(connectionString, queueName));
    })
    .Build();

host.Run();

注意事项 #

• Azure队列单次最多支持读取32条消息，若需处理更多，可循环调用读取方法
• 合理设置visibilityTimeout：如果处理耗时较长，需延长超时时间，避免消息被重新放回队列
• 务必在处理完成后调用DeleteMessageAsync，防止消息重复处理

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