💭П
А если специалист, то это ещё год.
Size: a a a
2021 August 16
💭П
Но он чистой воды экономист
💭П
И до этого мануальное тестирование
💭П
Может он с родителями живёт :-)))
💭П
Я только не понял смысла уйти с ИТ факультета и перевестись на экономический, и продолжать работать тестером. А не пойти в датасатанисты. Это загадка для меня.
DV
господа, кто-нибудь сталкивался с такой проблемой - вот есть celery и есть rabbitmq.
мы ставим таску в celery с очень большим eta (например 3 часа). ну или в случае ошибки делаем retry таски с этим eta.
rabbit абсолютно с нифига киляет воркер через 30 минут с ошибкой
в доках реббита нашел вот такое: https://www.rabbitmq.com/consumers.html#acknowledgement-timeout
а еще вот такое на stackoverflow:
мы ставим таску в celery с очень большим eta (например 3 часа). ну или в случае ошибки делаем retry таски с этим eta.
rabbit абсолютно с нифига киляет воркер через 30 минут с ошибкой
PRECONDITION_FAILED - delivery acknowledgement on channel 1 timed out. Timeout value used: 1800000 ms. This timeout value can be configured, see consumers doc guide to learn more
в доках реббита нашел вот такое: https://www.rabbitmq.com/consumers.html#acknowledgement-timeout
а еще вот такое на stackoverflow:
DV
DV
собственно кто-нибудь решал подобное нормальным способом, а не через увеличение
consumer_timeout на стороне реббита ?DV
Ну да
KK
Там фишка в том, что воркер вычитывает это сообщение из реббита, но не акнолоджит его до тех пора пока не выполнит. И вот тут и вступает в силу таймаут на реббите
DV
Он канал убивает
DV
И воркер падает сам
DV
ну и да, настройки у меня:
CELERY_ACKS_LATE = True
CELERYD_PREFETCH_MULTIPLIER = 1
DV
то есть acknowledge постфактум после завершения задачи
KK
Могу предложить решение только через передачу в celery меньшего ETA + в параметрах таски (или ещё как) передавать реальный ETA. При запуске таски проверять реальный ETA. Если он не 0 - вычитать из него время, которое прошло с момента добавления таски в очередь (его можно добавить всем таскам через обработчик
@before_task_publish.connect). И ставить таску повторно, только с уже уменьшеным "реальным" ETA.DV
звучит страшно 😄