170 похожих чатов

Привет, есть какие-нибудь библиотеки для фоновой обработки задач помимо celery

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

12 ответов

13 просмотров

каких сигналов? какого запуска останова?

Michael-Pokrovsky Автор вопроса
Michael Pokrovsky
от оси, термы, хабы и прочее

эм. а что там обрабатывать?

Michael-Pokrovsky Автор вопроса
Tishka17
эм. а что там обрабатывать?

ну как минимум иногда надо дождаться когда сообщение до конца обработается

Michael-Pokrovsky Автор вопроса
Tishka17
ой не факт

как не факт, вдруг на половину обработается, а на вторую половину SIGTERM придет -> риск неконсистентного состояния

Michael-Pokrovsky Автор вопроса
Tishka17
а если sigkill придет?

а не придет sigkill, не доходит он до процесса

Michael-Pokrovsky Автор вопроса
Tishka17
ну вот о том и речь

если ты стопаешь процессы cигкилом - очень печально это

Michael Pokrovsky
как не факт, вдруг на половину обработается, а на ...

для этого таски должны быть в идеале идемпотентными, а изменения состояния атомарными.

Похожие вопросы

Обсуждают сегодня

А как старый хаскел с новым стыковать ? потому как тут работает https://play.haskell.org/saved/C3xpMzcd, а вот тут https://stepik.org/lesson/7602/step/9?unit=1473 нет ошибка C...
Fedor
131
что насчет пагинга? на осдеве непонятно(
Vi Chapmann 🪙
26
Народ, кто шарит в расширенных разделах (EBR/EPR) на дисках с разметками MBR? Везде пишут (в вики рус/англ) в частности + другие источники смотрел, что первый сектор расширенн...
Eugene Krasnikov (ᴊɪɴ x)
1
Вопрос я правильно понимаю что в коде newtype ArrowMap k v = ArrowMap { getArrowMap :: k -> Maybe v } getArrowMap есть функция типа k -> Maybe v, если да, то не понимаю задач...
Fedor
64
Ребят, что лучше для реверса: гидра или ида?
En Vind Av Sorg
26
Делаю велосипед логгер. К сообщению хочу прикрутить некоторую информацию, типа, кем отправлено, какой уровень, и всякое такое. И тут подумалось мне, почему бы не хранить весь...
Serjone
24
Как Вы считаете нормально ли в двадцатых годах 21 века в ВУЗах Российской Федерации обучать студентов работе с TASM? Не слишком ли это "архаично"? (Если оффтоп или флейм для э...
Spiker01
52
Комрады, хотел уточнить. Проперть в OnDestroy юнита-хозяина по-прежнему доступна? И еще уточнение: finalization юнита наступает раньше или позже OnDestroy?
Ed Doc
48
Где-то есть статьи, как писать на OCaml после Kotlin (ну или похожей направленности)? Я привык к интерфейсам и наследованию классов, а здесь это выглядит совершенно не так.
Раскопки Майтрейи Коц
6
Продолжая диалог про свифт в проде – сейчас возник вопрос в активном наборе бекендеров. В основном в нашей компании мы фанаты Java Spring и полностью ей довольны. Однако найм ...
Guseyn
27
Карта сайта