Можете подсказать, как с помощью RabbitMQ реализовать такую схему: https://raw.githubusercontent.com/socialpandas/sid...
т.е. Worker6 генерирует для Worker7,8,9 задачи и 10 начинает работать только после завершения работы предыдущих?
черт.. а решение-то было близко :) спасибо за наводку - действительно, перекладывать результат выполнения 200 потоков в очередь, чтобы только воркер писал в базу выглядит наиболее красивым решением.
Идея интересная.. но результаты 200 потоков тоже надо где-то сохранять временно, пока последний не запишет все в базу. В моем случае каждый поток может вернуть что-то вроде сериализованного массива.
Задача - запрос наличия жилья у разных партнеров по разным параметрам. Например, есть 5 партнеров и 40 параметров (объединить в 1 запрос не представляется возможным). Т.е. на данный момент - 1 параметр к 1 партнеру = 1 поток (он же 1 коннект к базе). После сбора всех данных производится обработка (фильтрация, поиск лучших вариантов). Собственно, для обработки все результаты и пишутся в базу.
С выборкой данных проблем нет, только с записью.
Написано
Войдите на сайт
Чтобы задать вопрос и получить на него квалифицированный ответ.
т.е. Worker6 генерирует для Worker7,8,9 задачи и 10 начинает работать только после завершения работы предыдущих?