Всем привет! Поделитесь пожалуйста, как создать отложенные очереди? Допустим, я

хочу сделать паблиш, а консьюмеру дать сообщение после n-ое время

12 ответов

6 просмотров

вообще не рекомендуется, но для простых случаев подойдёт https://github.com/rabbitmq/rabbitmq-delayed-message-exchange

Как всегда, докину ссылку на свою репку, которую не рекомендую использовать в проде (как и плагин с делейд-эксченжем), но зато там в ридми есть в конце несколько объяснений с подводными камнями, ну и само решение как бы объясняет, почему кроля не надо для этого использовать напрямую, а лучше посмотреть в сторону всяких дедикейтед решений для скедулинга, если на нем предполагается строить сложную архитектуру.

Zhuman-Rakhat Автор вопроса

Что лучше использовать вместо rabbit на проде?

Зависит от стека. Ну не к вашему случаю ответ, конечно, потому что у вас задача не в скедулинге, а в отказоустойчивости состоит. Но если вдруг будет скедулинг, то: Hangfire, Quartz, Airflow, даже прости господи кронджобы кубера :)

Zhuman Rakhat
Что лучше использовать вместо rabbit на проде?

вопрос непонятен, почему не использовать rabbit на проде?

Zhuman-Rakhat Автор вопроса
Anton
вопрос непонятен, почему не использовать rabbit на...

Вообще не знаю, мне сказали на проде не очень то стабильная вещь, так как я впервые сталкиваюсь с такой проблемой, не знаю какое решение лучше подойдёт

Zhuman Rakhat
Что лучше использовать вместо rabbit на проде?

Тот же юрент для сбора метрик с самокатов зайца и использует

Zhuman-Rakhat Автор вопроса
Владислав Килин
Зависит от стека. Ну не к вашему случаю ответ, кон...

А к моему случаю что предложите? У меня стэк на Node Js

nikto _b
Тот же юрент для сбора метрик с самокатов зайца и ...

Вот тут было https://habr.com/ru/company/bastion/blog/669500/

Zhuman-Rakhat Автор вопроса
nikto _b
Тот же юрент для сбора метрик с самокатов зайца и ...

Имелось ввиду не стабильно, в моем случае, когда я подключаю отдельный плагин для отложенного вызова метода АПИ

Zhuman Rakhat
А к моему случаю что предложите? У меня стэк на No...

эйрфлоу должен вроде с жаваскриптом работать норм

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

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

Всем привет. Подскажите. Следующая ошибка при выполнении команды werf ci-env github --as-file - "unable to get synchronization client id: unable to get repo ghcr.io/*** tags: ...
2
pika.exceptions.ChannelClosedByBroker: (406, "PRECONDITION_FAILED - inequivalent arg 'x-message-ttl' for queue 'amo-crm.q' in vhost '/': received the value '60000' of type 'si...
Sergey
9
WERF_COMMIT_HASH если я правильно понимаю только внутри стапель сборки работает?
citius
2
Еще одну панику поймал: $ werf helm repo add --username gitlab --password ${CI_JOB_TOKEN} helm-werf ${HELM_REPO_V2_URL} "helm-werf" has been added to your repositories $wer...
citius
1
Всем привет 👋 может кто подсказать? Как мне добавить файлик без коммита в сборку stapel? С докерфайлом понятно Там allowContextAddFiles А как тоже самое сделать со stapel?
Sergeevich
5
Вот такая неприятность на stable и ea версиях: werf helm --namespace s4c upgrade --install --atomic --timeout 5m --set s4c.version=839185f3 --set s4c.deployEnv=staging -f d...
citius
6
Всем привет! Прохожу этот самоучитель. Дошел до # Настроим подключение к MinIO. mc alias set minio http://minio:9000 minioadmin minioadmin # Получим содержимое сохранённого...
Aleksandr
7
Всем доброго времени суток! Перестал запускаться сервер RabbitMQ, вижу по логам, что ругается на плагин, но по какой причине не могу понять. Можете помочь разобраться, куда ко...
Александр Семенов
2
https://habr.com/ru/companies/domclick/articles/500978/ Добрый день, подскажите, пожалуйста, насколько хорошая практика сделать вот такую структуру эксчейнджей и очередей для...
Sergey
5
Блин а мне как поумнеть ?
Toxin
191
Карта сайта