当 AWS KCL 中的 processRecords 失败时如何处理？

Question

我正在使用基于 KCL 的 nodejs 创建应用程序。在processRecords 函数中，我尝试使用http 请求将从kinesis 获得的记录发送到Web 服务。但是当web服务不可用时，http请求就会失败。我想停止 KCL 以从 kinesis 获取记录并向 pagerduty 发送警报。

有人知道怎么做吗？

Answer 1

将其作为一般策略而不是特定代码提供：

如果您还没有，请确保您已设置好 retry policy 和 exponential backoff 以防出现错误 - 这将处理大多数临时问题。

在您的情况下，您可能需要一个“永远重试”类型的策略，并在重试次数超过您定义的某个阈值时触发您的 pagerduty 警报（即：numRetries==30 或其他东西）。