【发布时间】:2019-02-01 00:17:55
【问题描述】:
我正在使用 Microsoft.WindowsAzure.Storage.Queue 库通过以下代码将消息从 Azure 函数推送到存储队列:
public void Enqueue(MyMessage myMessage)
{
string originalPayload = null;
try
{
payload = serializer.Serialize(myMessage);
var message = new CloudQueueMessage(payload);
cloudQueue.AddMessage(message);
}
catch (Exception ex)
{
throw ex;
}
}
这适用于小批量,但当每 5 分钟处理大约 200 条消息时,几乎一半的消息不会进入队列,即使该函数从未失败并且在所有尝试中都显示为成功。
所以我想在推送消息后添加一个验证步骤,我在想是否只有 PopReceipt 检查可以工作:
if ( string.IsNullOrWhitespace(message.PopReceipt) )
{
// the message was not added, do something
}
【问题讨论】:
标签: c# azure azure-functions azure-queues azure-storage-queues