如何通过Azure Logic Apps读取存储账户队列的全部消息？

针对你的问题，我分两个方向来拆解解答：

1. 能否获取队列的当前消息数？ #

可以，但要注意这是近似值。Azure存储队列提供了ApproximateMessagesCount属性，它能返回队列中当前可见消息的估算数量（不包含处于隐藏状态的消息）。这个值是后台异步统计的，和实际数量可能有小幅偏差，但足够用来判断需要循环拉取的大致次数。

举个.NET SDK的示例代码：

var queueClient = new QueueClient(connectionString, queueName);
var properties = await queueClient.GetPropertiesAsync();
long approximateMessageCount = properties.Value.ApproximateMessagesCount;
Console.WriteLine($"队列当前近似消息数：{approximateMessageCount}");

不过要提醒你：这个值不能用来精确控制拉取数量，因为在你获取数值和拉取消息的间隙，队列里的消息可能被其他客户端添加或删除。

2. 能否设置足够大的消息数量值一次性拉取所有消息？ #

不行。Azure存储队列的Get Messages操作有硬性限制：每次最多只能拉取32条消息。哪怕你设置的数值远大于32，服务端也只会返回最多32条。所以要遍历所有消息，必须通过循环拉取的方式，直到某次拉取返回空列表为止。

推荐的遍历流程： #

• 每次调用Get Messages时，设置maxMessages为32（最大值）
• 对返回的每条消息检查是否包含特定文本
• 根据业务需求，处理完消息后可以选择删除它，或者重新设置可见性（如果需要其他客户端处理）
• 重复上述步骤，直到拉取的消息列表为空，说明当前队列中没有可见消息了

示例代码（.NET）：

var queueClient = new QueueClient(connectionString, queueName);
string targetText = "你要找的特定文本";

while (true)
{
    // 每次拉取最多32条消息，设置30秒可见性超时（防止其他客户端重复获取）
    var messages = await queueClient.ReceiveMessagesAsync(maxMessages: 32, visibilityTimeout: TimeSpan.FromSeconds(30));
    
    if (messages.Value.Count == 0)
    {
        // 没有更多消息，退出循环
        break;
    }
    
    foreach (var message in messages.Value)
    {
        // 检查消息内容是否包含目标文本
        if (message.Body.ToString().Contains(targetText))
        {
            Console.WriteLine($"找到匹配的消息ID：{message.MessageId}");
            // 这里可以添加自定义处理逻辑，比如记录日志、标记消息等
        }
        
        // 处理完成后删除消息（如果不需要保留）
        await queueClient.DeleteMessageAsync(message.MessageId, message.PopReceipt);
    }
}

额外注意事项： #

• 如果队列中有处于隐藏状态的消息（比如被其他客户端拉取但未删除），这些消息不会被当前拉取操作返回，直到它们的可见性超时结束
• 如果你的业务需要处理所有消息（包括隐藏的），可以考虑调整可见性超时，或者确保其他客户端不会占用消息太久
• 循环过程中如果有新消息被添加到队列，循环会继续拉取这些新消息；如果只想遍历某一时刻的消息，可以先记录近似消息数，拉取对应次数后停止，但这种方式不绝对精确

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