Azure函数队列触发器-如果失败，如何将项目放回队列？

Question

我正在使用带有队列触发器的Azure Functions。

当函数运行时，它会从Azure队列中删除一个项目。然而，有时我的处理会失败，在这种情况下，我想重新申请该项目，并在以后进行处理。

如何在Azure函数和使用Node中实现这一点。js？

Answer 1

如果有人稍后正在寻找答案，这里有一个使用imago-azure存储包的代码示例：

const { Queues } = require('imago-azure-storage');
const q = new Queues(storageAccount, storageKey);

const QUEUE_NAME = 'testqueue';

(async() => {
    // Create the queue if it does not exist yet:
    await q.initializeQueues([QUEUE_NAME]);

    // Write a sample item to the queue:
    await q.put(QUEUE_NAME, { test: 12345 });

    // Retrieve up to 10 items, and if any of them fail,
    // retry processing them after 3600 seconds:
    let items = await q.fetch(QUEUE_NAME, 10, 3600);
    for (const { item, message } of items) {
        try {
          console.log(item);
          await doSomeWork(item); // <-- your function here

          // Items processed successfully, delete it from queue:
          await q.commit(message);
        } catch (error) {
          // Ignore errors, the item will be requeued automatically
          // in 3600 seconds.
        }
    }
})();

Answer 2

我所做的解决方法是创建一个绑定到触发函数的同一个队列。

 [FunctionName("FunctionsQueueTrigger")]
    public static async Task Run(
        [QueueTrigger("101functionsqueue")] string myQueueItem,
        [Queue("101functionsqueue")]  IAsyncCollector<string> myQueue)

在我的例子中，如果引发存储异常，代码为412（前提条件失败），我想将该项放回队列。

catch (StorageException ex)
        {
            if (ex.RequestInformation.HttpStatusCode == (int)System.Net.HttpStatusCode.PreconditionFailed) //412
            {
                log.LogWarning($"Putting item back to queue due to {ex.Message} error.");
                await myQueue.AddAsync(myQueueItem);
            }
        }

最后，该函数会从队列中删除当前项，但会添加一个具有相同内容的新项。

这可能不是最好的解决方案，但对我来说很有效。