Я пытался найти способ сделать следующее с помощью многопроцессорной обработки в python:
В моем проекте у меня есть один «производитель», который собирает некоторые данные через веб-сокет.Он собирает разные данные (активы на крипто-рынках) через один и тот же сокет.Теперь я хотел бы создать процесс для каждого типа данных (актив) и отправить только эти данные этому конкретному процессу.Итак, я постоянно получаю данные, и программа должна проверить данные и отправить их в соответствующий процесс.Процессы не заканчиваются, они просто ждут своих данных.
Можно ли динамически создать очередь для каждого дочернего процесса?если нет, могу ли я как-то добавить ключ к каждому сообщению и создать только одну очередь, а затем проверить его на дочерней стороне и получить ()?вторая, на самом деле, побила бы цель многопроцессорности, я полагаю.
У меня нет никакого кода по этому поводу с многопроцессорностью, потому что я застрял в начале ...
Я простоизучая многопроцессорность и практикуясь на этом примере, поэтому я бы хотел решить с многопроцессорностью
Спасибо!