Azure Functions - 写入表输出绑定时处理错误

Posted

技术标签:

【中文标题】Azure Functions - 写入表输出绑定时处理错误【英文标题】:Azure Functions - Handle Error while Writing to Table Output Bindings 【发布时间】:2019-04-08 05:39:42 【问题描述】:

我有一个 Azure 函数设置。它的触发器设置为 Service Bus Queue 消息。当 Function 被触发时,消息会以某种方式进行处理。如果在处理过程中遇到任何异常,我会处理该错误并将消息保存在 Azure 表存储集中作为输出绑定以用于日志记录。

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

错误详情

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

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

在这种情况下处理错误很重要,因为如果没有正确消费Service Bus Message,那么Service Bus Queue中的消息不会被删除,并且在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();

【问题讨论】:

【参考方案1】:

输入和输出绑定在函数范围之外执行,这就是为什么不能在函数内输入 catch 块的原因。如果您想捕获错误,您可以自己处理写入存储,而不是使用输出绑定。

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

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

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

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

【讨论】:

感谢您的详细解答。很高兴知道它不会进入无限循环。应该更仔细地阅读文档。

以上是关于Azure Functions - 写入表输出绑定时处理错误的主要内容,如果未能解决你的问题,请参考以下文章

添加 Azure 存储 Blob 容器输入绑定 Azure Functions Java

Azure Functions - Python(Blob 触发器和绑定)

Azure Functions:如何在 Azure 存储队列的绑定表达式中使用 POCO?

Azure Functions - Blob 流动态输入绑定

通过 Azure Functions UI 删除 CosmosDB 文档

Azure Functions with java - 如何获取写入函数的日志?