设置通过Azure函数输出绑定添加到Azure队列的消息的VisibilityTimeout

问题描述

我有一个TimerTrigger函数，并且输出绑定是Azure队列.

I have a TimerTrigger function and the Output binding is a Azure Queue.

这个想法是，计时器每10分钟运行一次，它将查看数据库中的一个视图，并遍历返回的所有行，并将它们作为消息添加到队列中.

The idea is that every 10 minutes the timer will run, it will look at a view in my database and iterate through any rows returned adding them to the queue as messages.

下面是我的示例TimerTrigger.在将消息添加到队列中时，它工作正常.

Below is my sample TimerTrigger. It worked fine adding messages to the Queue.

但是，在我的实际情况中，有些行将需要立即执行，而另一些行将需要几分钟的延迟(每行不同).我计划通过使用VisibilityTimeout处理消息来处理延迟.

However in my real world scenario some of the rows will require immediate execution while others will have a delay of some minutes (varies per row). I plan on handling the delay by using the VisibilityTimeout for the message.

不幸的是，通过字符串的绑定无法让我设置值. CloudQueueMessage.VisiblityTimeout(以下使用)为只读.

Unfortunately the binding via a string wouldn't let me set the value. CloudQueueMessage.VisiblityTimeout (used below) is readonly.

#r "Microsoft.WindowsAzure.Storage"

using System;
using Microsoft.WindowsAzure.Storage.Queue;

public static void Run(TimerInfo myTimer,  ICollector<CloudQueueMessage> outputQueueItem, TraceWriter log)
{
    log.Info($"C# Timer trigger function executed at: {DateTime.Now}");


    //- Add a message to be processed now.
    CloudQueueMessage msg = new CloudQueueMessage("Now");
    outputQueueItem.Add(msg);

    //- Add a message to be processed later.
    //- this code below won't work because NextVisibleTime is readonly.
    //- is there some way to set the VisibilityTimeout property before queueing?
    msg = new CloudQueueMessage("Later");
    DateTime otherDate = DateTime.Now.AddMinutes(3);

    msg.NextVisibleTime = otherDate;
    outputQueueItem.Add(msg);

}

有什么方法可以使绑定将消息添加到队列中，并让我根据需要按消息设置VisibilityTimeout消息吗?

Is there any way to have the binding add messages to the queue and let me set the VisibilityTimeout message by message as appropriate?

推荐答案

Azure函数存储队列的输出绑定仅使我们可以访问CloudQueueMessage，而不能让我们为消息设置VisibilityTimeout.

Azure Functions Storage Queue’s output binding only gives us access to the CloudQueueMessage which doesn’t let us set the VisibilityTimeout for a message.

我重写了代码以连接到Azure存储队列，然后手动将消息发布到队列中，而不是通过Azure Function输出绑定.

I rewrote my code to connect to the Azure Storage Queue and post the messages onto the queue manually rather than through Azure Function output binding.

请参见下文. .

#r "Microsoft.WindowsAzure.Storage"

using System;
using System.Configuration;
using Microsoft.WindowsAzure.Storage;
using Microsoft.WindowsAzure.Storage.Queue;

public static void Run(TimerInfo myTimer, TraceWriter log)
{
    log.Info($"Queue Notifications: {DateTime.Now}, {myTimer.Schedule}, {myTimer.ScheduleStatus}, {myTimer.IsPastDue}");

    //* Setup the connection to q-notifications, create it if it doesn't exist.
    var connectionString = ConfigurationManager.AppSettings["AzureWebJobsStorage"];
    var storageAccount = CloudStorageAccount.Parse(connectionString);
    var queueClient = storageAccount.CreateCloudQueueClient();
    var queue = queueClient.GetQueueReference("q-notifications");
    queue.CreateIfNotExistsAsync();

    //* Eventually this will come from iterating through a SQL Database View of messages that need queueing.
    //* For testing just show we can add two messages with different Visibilty times.
    CloudQueueMessage message;
    TimeSpan delay;

    //* Queue Message for Immediate Processing.
    message = new CloudQueueMessage("Now Message");
    queue.AddMessageAsync(message, null, null, null, null);

    //* Queue Message for Later Processing.
    delay = DateTime.UtcNow.AddMinutes(3) - DateTime.UtcNow;
    message = new CloudQueueMessage("Later Message");
    queue.AddMessageAsync(message, null, delay, null, null);

    //* Queue Message for Even Later Processing.
    delay = DateTime.UtcNow.AddMinutes(12) - DateTime.UtcNow;
    message = new CloudQueueMessage("Even Later Message");
    queue.AddMessageAsync(message, null, delay, null, null);
}

这篇关于设置通过Azure函数输出绑定添加到Azure队列的消息的VisibilityTimeout的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持！