Описание тега pyzmq
PyZMQ - это привязка Python для 0MQ (также пишется ZeroMQ, ØMQ или ZMQ), почти полностью написанная на Cython.
2
ответа
ZeroMQ, как подключиться к внешнему tcp сокету?
Подскажите, пожалуйста, как можно использовать для отправки сообщений ZeroMQ между двумя программами, расположенными на разных серверах, используя какой-то общий сокет? Со всеми локальными сокетами программа работает, но я не понимаю, как они распро…
24 янв '13 в 21:30
3
ответа
Отправить сообщение на несколько серверов pyzmq
Если у меня есть один клиент подключиться к нескольким серверам и попытаться отправить сообщение, socket = context.socket(zmq.REQ) socket.connect ("tcp://127.0.0.1:5565") socket.connect ("tcp://127.0.0.1:5566") socket.connect ("tcp://127.0.0.1:5567"…
16 июл '14 в 18:45
1
ответ
Чтение стандартного вывода с подчиненных узлов с помощью ipcluster
Я настроил кластер с помощью ipcluster start --n=8 затем доступ к нему с помощью from IPython.parallel import Client c=Client() dview=c[:] e=[i for i in c] Я запускаю процессы на подчиненных узлах (e[0]-e[7]), которые занимают много времени, и я бы …
22 мар '12 в 13:46
1
ответ
pyzmq recv_json не может декодировать сообщение, отправленное send_json
Вот мой код с извлеченными посторонними вещами: coordinator.py context = zmq.Context() socket = context.socket(zmq.ROUTER) port = socket.bind_to_random_port(ZMQ_ADDRESS) poller = zmq.Poller() poller.register(socket, zmq.POLLIN) while True: event = p…
12 дек '15 в 16:41
1
ответ
ZeroMQ PULL получает все сообщения в очереди
У меня есть большое (~100) количество "клиентов" PUSH, которые периодически (~1/ с) отправляют сообщение на "сервер" PULL. Сервер обрабатывает сообщения в пакетном режиме со скоростью ~2 пакета в секунду. Размер пакета не является фиксированным - в …
15 май '17 в 13:36
1
ответ
Обработка клавиатурных прерываний в асинхронном режиме zmq
Я делаю сервер ZeroMQ в pyzmq с помощью asyncio, Я пытаюсь изящно справиться с остановкой сервера, но документации по асинхронному модулю очень мало, и, похоже, нет простого способа справиться с остановкой текущего опроса / ожидания. Остановка цикла…
18 авг '16 в 13:20
1
ответ
Очереди сообщений для управления внешней программой на Python через Django
Я использовал в предыдущем проекте ZeroMQ для отправки сообщений между двумя разными программами Python на разных серверах. Теперь у меня есть программа, для которой я хотел бы использовать Django в качестве внешнего интерфейса. В большинстве случае…
04 янв '16 в 21:01
1
ответ
Flask и ZMQ сокет не могут отправлять данные в маршрут
Я пытаюсь отправить данные с помощью ZMQ.socket, но он работает, но при маршруте FLASK сообщение не отправляется. Розетка открыта, я вижу ее в netstat, но если я сделаю tcpdump -i 4999 У меня ничего нет. Я использую Uwsgi с Nginx и FLASK. пример код…
06 июн '18 в 14:31
1
ответ
Как использовать два цикла событий в приложении Python
Допустим, у меня есть класс, который использует zmq для передачи и вывода сообщений. И я хочу управлять им с помощью RPC, чтобы создать для него удаленный фасад. Как я могу это сделать? class Processor() def init() state = AddHeaderState() # There i…
11 авг '14 в 10:13
0
ответов
Самый простой сервис-обнаружение с pyzmq?
Я хотел бы иметь возможность сделать что-то вроде этого: Обнаружение службы Python: Рекламировать службу в локальной сети Но без операторов time.sleep() - все должно работать вне цикла событий pyzmq. Как это можно переписать в стиле 0mq? РЕДАКТИРОВА…
29 июн '14 в 11:09
0
ответов
Ни Anaconda Navigator, ни ноутбук Jupyter не откроются
Я недавно установил Anaconda на моем Mac (под управлением OS X 10.8.5), и у меня возникло несколько ошибок: (1) Когда я пытаюсь открыть Anaconda Navigator из папки anaconda3, значок отображается в моей док-станции, а затем быстро исчезает. (2) Когда…
26 июн '18 в 18:59
1
ответ
ZeroMQ: как узнать, какой порт использует PAIR-сокет?
Есть ли способ увидеть, какой порт ZeroMQ (на самом деле pyzmq) порт подключен после подключения?Например... import zmq context = zmq.Context() socket = context.socket(zmq.PAIR) port = socket.bind_to_random_port("tcp://*") # some other code that mig…
28 авг '17 в 22:43
1
ответ
ZeroMQ PubSub не работает с Pyzmq
Возможно, что-то очень маленькое, чего мне не хватает, но я не могу получить простой пример pub-sub, работающий на Python, используя официальный пакет Pyzmq ( https://github.com/zeromq/pyzmq). Я использую последнюю стабильную версию ZeroMQ 4.0.3 и м…
18 дек '13 в 12:28
1
ответ
Доступ к экземпляру работника сельдерея внутри задачи
Я хочу использовать ядра Jupyter в сторону сельдерея. Для каждого работника сельдерея будет одно ядро Jupyter. Для достижения этого я переопределяю значение по умолчанию Worker класс сельдерея, при инициализации рабочего я запускаю ядро jupyter …
16 мар '17 в 12:33
0
ответов
Ядро IPython зависает при взаимодействии
Я пытаюсь создать ядро IPython и выполнить там код. Я следую за двумя ответами в разделе Подключение к удаленному экземпляру IPython. /questions/45252506/podklyuchenie-k-udalennomu-ekzemplyaru-ipython/45252558#45252558 и обновленная версия /questi…
10 мар '18 в 06:54
1
ответ
Как установить pyzmq "--with-pgm"
У меня установлена версия zmq 4.1.3 и pyzmq 15.2.0 на моем компьютере (я полагаю, через pip, но сейчас не помню). Мне нужно подключиться к сокету UDP epgm, но появляется сообщение об ошибке "Протокол не поддерживается". Я искал обширные просторы и…
12 май '16 в 04:31
1
ответ
Отправлять клиентские запросы брокеру только тогда, когда работник доступен, а брокер доступен
С ZeroMQ для распределенного обмена сообщениями я использую пример кода, предоставленного для параноидального пиратского паттерна в python. У меня есть один клиент (потенциально может быть больше клиентов), брокер и несколько работников. Я изменил п…
07 авг '16 в 19:46
1
ответ
Ошибка установки zmq (ZeroMQ)
Я пытаюсь установить узел модуля ZMQ Я ссылался на этот https://github.com/JustinTulloss/zeromq.node/wiki/Installation Однако я получаю эту ошибку при установке модуля 0 info it worked if it ends with ok 1 verbose cli [ 'C:\\Program Files (x86)\\nod…
12 май '15 в 14:02
1
ответ
pyinsataller пропускает библиотеки при создании программ с использованием pyzmq
Я пытаюсь использовать pyinstaller для создания исполняемого файла моего рабочего клиента. Клиент использует ZMQ для связи с сервером. Но, к сожалению, pyinstaller, кажется, пропускает некоторые библиотеки при сборке zmq. Вот минимизированный пример…
10 сен '17 в 10:03
1
ответ
Отправление правильной информации из распределенной работы по параллельным запросам
Я создал приложение Flask+nginx+gunicorn, которое взаимодействует со службой через сокет пары zmq, который, в свою очередь, отправляет запрос распределенным работникам и возвращает результат. Однако я не проверял, чтобы правильная информация отправл…
04 ноя '13 в 01:13