node.js - Azure 存储队列 - Cosmos DB 输出 - 错误处理

Question

我们有一个 Azure js 函数，它执行一些操作，然后输出以触发存储队列。存储队列输出插入到 Cosmos DB 中。我们的 Cosmos DB 有一定数量的可用 RU，在流量高峰期间，RU 将被超出。在这种情况下，数据库插入似乎会失败并返回 429，需要重试。由于插入被作为存储队列的“输出”处理，我们不知道如何处理错误，因为我们的代码永远不会直接看到错误。

我已经简要地阅读过有关“毒药队列”的内容，但我认为我还没有完全理解。如果上述操作失败(5次尝试后？)，该项目是否会自动进入新创建的有毒队列？除了正常操作之外，更新我们的存储队列函数以尝试处理有毒队列中的项目是否有意义？

队列存储示例代码:

module.exports = function(context, myQueueItem) {
    context.bindings.outputDocument = myQueueItem;
    context.done(); //insert happens here?
};

Answer 1

是的，默认情况下，重试 5 次后，消息将被放入有害队列中。您可以创建另一个函数来监听该队列(使用相同的函数实际上没有意义)或使用某种计划的触发器+脚本在非高峰时段处理这些消息。