如何處理AWS KCL中processRecords失敗的問題？

Question

我正在創建一個基於KCL的nodejs應用程序。在processRecords函數中，我嘗試通過http請求將從kinesis獲得的記錄發送到Web服務。但是當Web服務不可用時，http請求將失敗。我希望KCL停止從kinesis獲得記錄併發送警報給pagerduty。

任何人都知道該怎麼做？

Answer 1

提供這種更作爲一般的策略，而不是具體的代碼：

如果你沒有準備好，確保你已經安裝了良好retry policy與exponential backoff在錯誤的情況下 - 這將掌握大部分臨時有事。

對於您的情況，您可能需要一個「重試永久」類型策略，並在重試次數超過您定義的閾值（即：numRetries == 30或某物）時觸發您的pagerduty警報。