gpt4 book ai didi

javascript - Azure Functions - 写入表输出绑定(bind)时处理错误

转载 作者:行者123 更新时间:2023-11-29 20:40:51 24 4
gpt4 key购买 nike

我有一个 Azure 功能设置。其触发器设置为服务总线队列消息。当函数被触发时,消息将以某种方式进行处理。如果在处理时遇到任何异常,我会处理该错误并将消息保存在 Azure 表存储中,设置为输出绑定(bind)以用于日志记录。

我想处理向输出绑定(bind)写入内容时引发的任何错误。我该怎么做呢?

错误详细信息

我在写入输出绑定(bind)(表存储)时遇到的错误之一是某些键的值无法保存。例如消息中的键之一是 time,其值为 number 类型。写入此数据时,我遇到了异常,即键的值无法容纳 Int32 数字。我认为表存储默认情况下尝试将数字转换为 Int32 但失败了。为了解决这个问题,我将所有键转换为具有字符串值。现在我可以保存了。

但我仍然想在写入表存储输出绑定(bind)时处理任何不可预见的错误。

在这种情况下,处理错误很重要,因为如果服务总线消息未正确使用,则服务总线队列中的消息不会被删除,并且在 Azure Function 执行完成后,该消息会再次触发该函数,并且 Function 进入无限循环。

以下是Azure函数的示例

module.exports = async function (context, mySbMsg) {
try{
// process service bus message
await processMsg(mySbMsg);
} catch(e) {
// if processing fails, save the message in Azure table
try{
// my own try to handle errors, but was unsuccessful
await new Promise(function (resolve, reject) {
context.bindings.tableBinding = [];
context.bindings.tableBinding.push({
PartitionKey: mySbMsg.id|| "unknown",
RowKey: time + "",
errorMessage: e.message || "",
...mySbMsg
})
resolve();
});
} catch (e) {
// do something HERE;
// exception on output binding didn't brought me here
}
}
context.done();
}

最佳答案

输入和输出绑定(bind)在函数范围之外执行,这就是您无法在函数内输入 catch block 的原因。如果您想捕获错误,您可以自己处理对存储的写入,而不是使用输出绑定(bind)。

但是,如果无法写入存储,您的服务总线队列将不会无限循环地触发该函数。服务总线限制重试次数,一旦达到该限制,消息就会移至单独的死信队列以避免无限循环。其中的消息不会过期 - 它们将一直保留在那里,直到您准备好处理它们或删除它们。

enter image description here

默认最大传递计数为 10,您可以在队列的属性边栏选项卡上进行配置。

就处理死信队列中的消息而言,我发现Service Bus Explorer非常有帮助。它使得查看 DLQ 中的消息,然后将它们推回主队列或删除它们变得相当简单。

您还可以以编程方式访问 DLQ 并构建自动化系统来处理这些消息。但是,由于消息无法从那里发送,因此如果您的 DLQ 处理程序无法解析消息,您可能会陷入循环。

关于javascript - Azure Functions - 写入表输出绑定(bind)时处理错误,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/55566849/

24 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com