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

Question

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

有谁知道该怎么做？

Answer 1

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

如果您还没有，请确保您已经设置了一个良好的重试策略，并在出现错误时使用指数退避- 这将处理大多数临时问题。

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