Как с этим справиться, когда в AWS KCL произошел сбой processRecords?

Question

Я создаю приложение с nodejs на основе KCL. в processRecords Я попытался отправить записи, полученные из кинесиса, в веб-сервис с запросом http. Но когда веб-сервис недоступен, http-запрос не будет выполнен. Я хочу, чтобы KCL прекратил получать записи от kinesis и отправлять оповещения в pagerduty.

Кто-нибудь знает, как это сделать?

Answer 1

Предоставляя это больше как общую стратегию вместо конкретного кода:

Если вы этого еще не сделали, убедитесь, что вы настроили хорошую политику повторных попыток с экспоненциальным откатом в случае ошибок - это решит большинство временных проблем.

В вашем случае вы, вероятно, захотите политику типа "повторить навсегда" и отключите оповещение pagerduty, когда число повторных попыток превысит определенный вами порог (то есть: numRetries==30 или что-то еще).