Существуют ли способы (функции) сохранения данных SQS при возникновении ошибки? - PullRequest
0 голосов
/ 20 февраля 2019

Предполагается, что в процессе чтения данных SQS возникает проблема, и обработка выполняется снова с использованием данных SQS.

В этом случае существуют ли какие-либо функции для сохранения данных SQS?

В качестве предполагаемого примера:

  1. Произошла ошибка при обработке с + fargate
  2. Сохраняет данные SQS
  3. Оператор подтвердил эвакуациюданные и ненормальное содержание.Считается, что возможна повторная передача
  4. Выполнить обработку снова, используя сохраненные данные

1 Ответ

0 голосов
/ 20 февраля 2019

Вы, вероятно, обнаружите, что Amazon SQS делает это для вас автоматически.

Общий поток:

  • Сообщения помещаются в очередь Amazon SQS
  • Workers извлечение сообщений из очереди из очереди
  • Как только сообщение извлечено из очереди, оно остается в очереди, но помечается как ' invisible '
  • Как только работник обработал сообщение, он удаляет сообщение из очереди
  • Однако, если сообщение не будет удалено в течение указанного периода времени, сообщение будет автоматически снова появляется в очереди, готовый к обработке другим работником
  • Если это происходит более определенного числа раз, сообщение может быть перемещено в очередь недоставленных сообщений для дальнейшего изучения и обработки

Таким образом, если во время обработки сообщения SQS произойдет ошибка, она автоматически появится позже и будет обработана снова.

См .: AmazonSQS VisibiliТайм-аут

...