Те итерационные петлевые решения не соответствовали моим потребностям. Они были слишком медленными для больших чисел. Поэтому я сделал свою собственную версию:
https://github.com/leonardosantos/momentjs-business
Надеюсь, вы сочтете это полезным.
Состояние FETCH_ERROR преобразуется в ОШИБКУ после нескольких последовательных попыток (устанавливается fetch.error.count ). Как только это произойдет, кортеж отправляется в потоке удаления с помощью AbstractStatusUpdaterBolt , и если у вас подключен DeletionBolt, то URL-адрес будет удален из индекса содержимого Elasticsearch. Он останется в индексе состояния, хотя и будет пересматриваться или не основываться на расписании для ОШИБК.