如何处理 AWS Lambda 函数中的进程退出以刷新一些需要发送的数据？

如何处理 AWS Lambda 函数中的进程退出以刷新一些需要发送的数据？"/>

如何处理 AWS Lambda 函数中的进程退出以刷新一些需要发送的数据？

我正在使用分析库（Segment）来跟踪 Lambda 函数中的事件。该库对事件进行排队并定期对其进行批处理。该函数定期退出而不刷新所有事件。我想挂钩进程退出事件并在进程退出之前刷新它们。

我已经尝试处理我认为会在退出时发送到 Lambda 函数的信号，但这段代码不会执行：

// handle lambda shutdown to flush events
['SIGINT', 'SIGTERM'].forEach((code) => process.on(code, async () => {
  await analyticsClient.closeAndFlush()
  process.exit()
}))

是否可以挂钩函数进程在退出时收到的信号？如果是这样，我怎样才能做到这一点？

Lambda 支持 正常关机，用于具有 注册扩展 的功能。当 Lambda 服务即将关闭运行时时，它会向运行时发送一个 SIGTERM 信号，然后发送一个 SHUTDOWN.

在关闭阶段，Lambda 关闭运行时，提醒扩展让它们干净地停止，然后删除环境。 Lambda 向每个扩展程序发送一个 SHUTDOWN 事件，它告诉扩展程序环境即将关闭。

关机阶段的上限为 2 秒。如果运行时或任何扩展没有响应，Lambda 将通过信号 SIGKILL 终止它。 关闭阶段的最长持续时间取决于注册扩展的配置：

• 0 ms – 一个没有注册扩展的函数
• 500 ms – 具有已注册内部扩展的功能
• 2,000 毫秒 – 具有一个或多个已注册外部扩展的函数

您可以在此处找到有关扩展的更多信息：Runtimes-extensions

最简单的测试方法是为现有的 lambda 函数启用 Amazon CloudWatch Lambda Insights。

示例代码：

process.on('SIGTERM', async () => {
    // perform actual clean up work here. 
    await new Promise(resolve => setTimeout(resolve, 200));
    process.exit(0)
});

NodeJS 示例代码