У меня есть API, предоставляемый через API-шлюз, с помощью которого клиенты моего API с разными clientIds (скажем, clientId1, clientId2, clientId2 и c) загружают фид. Для каждого триггера API после некоторой обработки генерируется уникальное событие, уникальное для клиента. Событие используется последующими сервисами. Поскольку шлюз API имеет ограничение полезной нагрузки в 10 МБ, клиент должен загружать фид в нескольких вызовах API и, следовательно, генерировать несколько повторяющихся событий.
В настоящее время это заканчивается генерацией дублированных событий, которые используются нисходящей службой. , Чтобы избежать повторяющихся событий, я думаю временно где-то хранить эти события и запускать расписание, чтобы идентифицировать уникальные события каждые x часов, а затем уведомлять последующие сервисы с уникальными событиями, а не перегружать их дублирующимися событиями.
Механизм уведомления для нисходящих сервисов уже существует, поэтому в этом нет необходимости.
Пожалуйста, предоставьте AWS решения для достижения следующих целей:
- Запланируйте работу. Облачные часы - один из таких примеров. Имеет ли он какие-либо функции для анализа временно сохраненных событий?
- Сохраняет уникальные события и извлекает события через x часов. К сожалению, максимальное время опроса SQS составляет 20 секунд.