должен брать все новые данные из таблицы и их обрабатывать. У меня есть два варианта как это сделать:
1) Заставить сервис 1 писать в основную таблицу все данные и в таблицу "очередь на обработку" только айди записи из основной. Сервис 2 будет пулить очередь и удалять из нее обработанные записи
2) Поставить нотифай на обновления основной таблицы и в качестве пейлоуда слать rowid записи с которой надо начинать обработку данных. Но вопрос, стекаются ли нотифаи если слушатель мертв/не запущен?
И второй вопрос, не херню ли я выдумал? Не изобретаю ли я велосипед?
Для очередей редис есть вроде.
Обсуждают сегодня