如何在不出列的前提下检查Azure存储队列是否包含特定消息

我正在为存储队列触发的Azure Function编写集成测试，需要确认函数是否已成功处理消息，或是将消息转移到了死信队列（poison queue）。有没有方法可以在不将消息出列的前提下，在队列中搜索特定消息？

我最初的实现思路是获取已发送消息的messageId和popReceipt，尝试更新该消息，若找不到目标消息则抛出异常，实现代码如下：

public async Task<bool> IsMessageInQueue(string messageId, string popReceipt, string queueName)
{
    try
    {
        var client = new QueueClient(_storageConnectionString, queueName);
        _ = client.UpdateMessageAsync(messageId, popReceipt);
        return true; // 消息存在于队列中
    }
    catch (Exception)
    {
        return false; // 消息不存在于队列中
    }
}

调用逻辑如下：

var sendMessageResponse = await client.SendMessageAsync(queueMessage);
var messageId = sendMessageResponse.Value.MessageId;
var popReceipt = sendMessageResponse.Value.PopReceipt;

var isProcessing = IsMessageInQueue(messageId, popReceipt, "processing");
var isPoisoned = IsMessageInQueue(messageId, popReceipt, "processing-poison");

若消息还未被函数拾取、仍在processing队列中，isProcessing会正确返回true，但问题是当消息被移到poison queue时messageId会发生变更，因此isPoisoned始终返回false。

方案更新 #

感谢@gaurav-mantri的建议，我已调整方法使用PeekMessagesAsync实现无出列搜索消息，该方案不受死信队列消息messageId变更影响，具体实现如下：
调整后的核心逻辑为：发送测试消息时先记录消息的唯一标识（如内容哈希、自定义测试标记），调用PeekMessagesAsync批量读取队列消息（该操作不会使消息出列，也不会修改消息的可见性、popReceipt等属性），通过消息内容匹配判断目标消息是否存在。

using System.Security.Cryptography;
using System.Text;
using Azure.Storage.Queues;

// 工具方法：生成消息内容的唯一哈希标识
private string GetMessageUniqueIdentifier(string messageContent)
{
    using var sha256 = SHA256.Create();
    var contentBytes = Encoding.UTF8.GetBytes(messageContent);
    var hashBytes = sha256.ComputeHash(contentBytes);
    return Convert.ToBase64String(hashBytes);
}

/// <summary>
/// 无出列检查目标消息是否存在于指定队列
/// </summary>
/// <param name="messageIdentifier">消息唯一标识</param>
/// <param name="queueName">目标队列名</param>
/// <param name="maxPeekCount">单次最多拉取的消息数，最大支持32</param>
public async Task<bool> IsMessageInQueue(string messageIdentifier, string queueName, int maxPeekCount = 32)
{
    var queueClient = new QueueClient(_storageConnectionString, queueName);
    var peekedMessages = await queueClient.PeekMessagesAsync(maxPeekCount);
    
    foreach (var message in peekedMessages.Value)
    {
        var currentMessageId = GetMessageUniqueIdentifier(message.MessageText);
        if (currentMessageId == messageIdentifier)
        {
            return true;
        }
    }
    return false;
}

调整后的调用逻辑：

// 构造测试消息
string testMessageContent = "自定义测试消息内容";
string messageIdentifier = GetMessageUniqueIdentifier(testMessageContent);

// 发送消息到队列
var sendResponse = await queueClient.SendMessageAsync(testMessageContent);

// 等待Azure Function处理完成（可根据实际业务逻辑调整等待时长）
await Task.Delay(TimeSpan.FromSeconds(5));

// 检查消息状态
bool isInProcessingQueue = await IsMessageInQueue(messageIdentifier, "processing");
bool isInPoisonQueue = await IsMessageInQueue(messageIdentifier, "processing-poison");

if (isInProcessingQueue)
{
    // 消息未被函数拾取，仍在处理队列
}
else if (isInPoisonQueue)
{
    // 消息处理失败，已进入死信队列
}
else
{
    // 消息已被函数成功处理
}

注意事项 #

• PeekMessagesAsync单次最多可拉取32条消息，若队列积压消息较多，可多次调用分页拉取全部消息再匹配
• 若消息体包含动态生成字段，可在消息结构中新增专门的测试标记字段（如TestId），直接匹配该字段即可，无需对全量消息内容做哈希

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