Подскажите пожалуйста, есть две яндекс функции, которые обмениваются между собой

сообщенями через YMQ.
Одна функция пишет в очередь, вторая запускается по триггеру из очереди.

Чтобы обеспечить гарантированное чтение в случае отказа функции которая читает из очереди по триггеру.
Я создал две FIFO очереди, в первую я записываю сообщения, и в случае проблем с чтением отправляю во вторую очередь.
Во второй очереди сделал так же, в случае не прочтения отправляю в первую очередь.
И добавил два триггера на чтение сообщений на каждую из очередей.

Правильно ли я делаю, чтобы обечпечить 100% чтение сообщений в случае отказа функции которая читает?

5 ответов

8 просмотров

Ну ты сообщение или почитал или нет. Если не почитал, то оно осталось в очереди

Максим-Кот Автор вопроса
Denis
Ну ты сообщение или почитал или нет. Если не почит...

Не до конца понимаю. Если триггер сработал, и фунция отработала без ошибок = прочитал сообщение Если триггер сработал и фунция упала = не прочтал сообщение, и произойдет повторная попытка. Правильно?

Максим Кот
Не до конца понимаю. Если триггер сработал, и фунц...

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

Сообщение полученное из очереди на заданное время помечается что оно находится в обработке. Если в течение этого таймаута сообщение не будет обработано и удалено, оно снова станет доступно для чтения. Триггер делает это все за вас. Он вычитывает сообщение и если функция-обработчик не выбросит исключения, то по окончании выполнения фции триггер удалит сообщение из очереди. YMQ реализует API Amazon SQS. Вы можете обратиться к туториралам про SQS, чтобы подробнее разобраться с тем как оно работает.

Кмк, fifo лучше не использовать в таком сценарии, а триггер вешать именно на ymq

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

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

Подскажите, а есть vault lite или ченить такое?) А то нужен вольт для похода в вольт, но весит он ~500 мб) как-то многовато для парочки запросов ))
Alexandr Orloff
17
Всем привет, есть небольшая проблема Есть такой скрипт document.addEventListener('DOMContentLoaded', function () { const sliderTabs = document.querySelectorAll('.s...
A da
8
@go1337 @dblackCat Привет. Все ещё дрочусь с fastpanel. Добавил второй домен который должен смотреть в рут того же сайта, но так как это просто домен, а не сайт, я не могу ему...
Ross 🦴
9
До речі, в ево нема можливості чи якого розширення щоб з адмінки з телефона зайти і терміново щось в верстці поправити?
Женя
7
кто-нибудь пользуется тайм-трекерами во время работы? так много разных нагуглил, может есть что-то популярное
Lencore
8
Пацаны. Я разрабатываю софт для инвайтинга на телетон, и столкнулся с такой проблемой, в один из чатов не могу приглашать никого, не дает добавлять, в то же время через официа...
Kernel Panic
11
Скажите, а кому нужен Currency как отдельный плагин вместо полноценного ecommerce в OctoberCMS? Кто-то использует его уже или планирует в будущем? Может я что-то не понимаю?
Igor
13
Розмовами про Рево мені нагадали часи, коли шаблони правилися прямо в адмінці. Хто в курсі, чому відійшли від цієї практики, так блейд не працює? Доволі зручно ж було (інколи)
Женя
3
Всем добрый вечер, Рад оказаться в кругу единомышленников. Начинаю погружаться в мир .net веба. Зовут Ерасыл 🖖 У меня назрел вопрос: Какой процент проектов, прошедшие через в...
Ерасыл
6
Чому? Да тому що без GiT не уявляю нормального проекта а коли код в базі то то так собі
Dmytro Lukianenko
3
Карта сайта