следующем
Есть парсер, которому скармливается список зарегистрированных в сервисе пользователей.
Он берет каждого пользователя, с его данными лезет в сторонний api, смотрит наличие новых записей, пишет новые записи в базу и отправляет в rabbitMq для обработки этих записей.
Вопрос. Как обеспечить систему так, чтобы при горизонтальном масштабировании парсера и подписчиков одна и та же запись обрабатывалась и записывалась в базу только один раз?
Например с одним пользователем должен работать один инстанс
Беда в том, что на 5к пользователей 5к инстансов тоже не создать Если только оркестрировать 10 инстансов, чтобы они работали с разными пользователями - но тоже хз как это сделать Можно только попробовать их грузить в очередь брокера каждые n миллисекунд. Но честно я не знаю, насколько правильно так делать
Выше правильно написали Идея в том, что с пользователем работает один инстанс, а не по инстансу на каждого пользователя
А в брокерах есть какая нибудь тулза, чтобы раз загрузить в него записи, и эти записи будут обрабатываться разными инстансами? Чтобы подписчики брали эти записи с самого начала одну за одной, а когда вс обработали - возвращались в начало списка?
Обсуждают сегодня