и dramatiq и желательно с большим контролем на паблишерами и подписчиками? Например, когда жестко описываешь логику работу консумера, где принимаешь или возвращаешь сообщение обратно в очередь, явно вызываешь паблишеры и передаешь им сообщения (а не как в celery/dramatiq через обычные вызовы функций). Я понимаю, что можно все это дело самому оформить через pika, но базовые вещи реализовывать не хочется типа сериализации/десериализации сообщений, политики остановки и запуска, обработки сигналов и прочее
каких сигналов? какого запуска останова?
от оси, термы, хабы и прочее
эм. а что там обрабатывать?
ну как минимум иногда надо дождаться когда сообщение до конца обработается
как не факт, вдруг на половину обработается, а на вторую половину SIGTERM придет -> риск неконсистентного состояния
а если sigkill придет?
а не придет sigkill, не доходит он до процесса
ну вот о том и речь
если ты стопаешь процессы cигкилом - очень печально это
я ещё и кабель из компа выдергиваю
для этого таски должны быть в идеале идемпотентными, а изменения состояния атомарными.
Обсуждают сегодня