Реализация запланированного шлюза между двумя очередями SQS

Question

У меня есть две очереди SQS, скажем, queueA и queueB.queueA подписался на несколько тем SNS и продолжает получать сообщения.queueB - это тот, кто на самом деле обрабатывает эти сообщения.

Но мое требование состоит в том, чтобы эта обработка происходила каждый день в течение фиксированного периода, скажем, с 9:00 до 18:00 ежедневно.

Нет способа контролировать /обработка расписания внутри queueB, другими словами, queueB обрабатывает сообщения, как только получает.

Я хочу иметь механизм ворот / дверей между queueA и queueB.Эти ворота открываются в 9 утра каждый день, остаются открытыми до 6 вечера и закрываются ровно в 6 вечера.Когда дверь открыта, сообщения могут передаваться из очереди A в очередь B, включая сообщения, поступившие в очередь A в течение этого периода, а также сообщения, поступившие в «закрытое время» и ожидающие открытия шлюза.

Answer 1

Есть много способов сделать это, но вам придется написать процесс, который перемещает сообщения из одной очереди в другую самостоятельно - это должно быть довольно просто.Чтобы сделать его более гибким, настройте параметры этого процесса таким образом, чтобы он останавливался через определенное время.

Затем вы можете управлять этим процессом с помощью одного из:

• заданий cron в EC2
• Запланированное событие Cloudwatch
• любой другой выбор инструментов планирования