Вопросы по теме 'pyzmq'
Чтение стандартного вывода с подчиненных узлов с помощью ipcluster
Я настроил кластер, используя
ipcluster start --n=8
затем получил к нему доступ, используя
from IPython.parallel import Client
c=Client()
dview=c[:]
e=[i for i in c]
Я запускаю процессы на подчиненных узлах (e[0]-e[7]), которые...
708 просмотров
schedule
11.12.2022
Почему gevent.sleep(0.1) необходим в этом примере для предотвращения блокировки приложения?
Я рву на себе волосы из-за этого. Я пытаюсь получить простейшие примеры работы с zeromq и gevent. Я изменил этот сценарий, чтобы использовать сокеты PUB/SUB, и когда я запускаю его, сокеты «сервера» зацикливаются навсегда. Если я раскомментирую...
3132 просмотров
schedule
11.09.2023
ошибки ipython 0.13 zmq
Я сталкиваюсь со странным поведением кластера ipython. Расчеты заканчиваются, но многие результаты так и не доходят до клиента (и движки просто простаивают после завершения первого расчета).
Подозреваю, что с zmq что-то не так, потому что 1) время...
581 просмотров
schedule
08.02.2023
ZMQ - libzmq.so.3: не удается открыть общий объектный файл: нет такого файла или каталога
Я пытаюсь внедрить zeroMQ в свое приложение, следуя этим рекомендациям , чтобы установить ZMQ , поэтому пока здесь все работает нормально. У меня есть эта строка кода в моем приложении:
ZMQ.Context m_context = ZMQ.context(1);
но над...
10932 просмотров
schedule
07.01.2023
Получить все доступные сообщения из сокета ZeroMQ (pyzmq).
Есть ли хороший способ получить все доступные сообщения в сокете zmq? Особенно при использовании Poller.
Или единственное решение - продолжать вызывать неблокирующий recv() и до тех пор, пока ничего не останется?
Редактировать :
Думаю, я...
1734 просмотров
schedule
06.12.2022
Как я могу найти адрес TCP для другого компьютера для передачи через Ethernet?
Мне нужно передать данные через pyzmq через два компьютера, соединенных кабелем Ethernet. Я уже настроил скрипт, который правильно работает на том же компьютере, но мне нужно найти tcp-адрес другого компьютера для связи. Оба работают под управлением...
207 просмотров
schedule
03.07.2023
Python ZMQ и многопроцессорность вызывают zmq.error.ZMQError: прерванный системный вызов
У меня есть скрипт Python, в котором я привязываю несколько (например, 5) сокетов приемника ZMQ следующим образом:
receiver_1 = context.socket(zmq.PULL)
receiver_1.bind("tcp://*:5555")
...
receiver_5 = context.socket(zmq.PULL)...
1967 просмотров
schedule
17.04.2023
Отправить сообщение на несколько серверов 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")...
1235 просмотров
schedule
23.05.2022
Как получить целое число/число с плавающей запятой из строкового представления (массива байтов), доставленного в python с помощью zmq/zeromq?
Я использую сервер C++ и несколько клиентов Python с библиотекой zmq ( ZeroMQ ). Я хочу отправить клиентам float и integer .
Я прочитал руководство для zmq , но у меня возникла проблема с отправкой чего-либо, кроме char array из кода...
1209 просмотров
schedule
09.03.2023
Безопасность потока опроса ZeroMQ
У меня есть поток, который опрашивает ZMQ Poller:
poller.poll(timeout)
Этот поток также получает и отправляет обратно сообщения через сокеты, зарегистрированные в опросчике.
Затем у меня есть еще один поток, который может, в конце концов,...
1915 просмотров
schedule
11.06.2022
ZMQ: сбой REQ/REP с несколькими одновременными запросами и опросом
Я столкнулся со странным поведением с ZeroMQ, которое я пытался отлаживать весь день.
Вот минимальный пример сценария, который воспроизводит проблему. Его можно запустить с помощью Python3.
Запускается один сервер с REP-сокетом и пять клиентов...
594 просмотров
schedule
11.04.2023
ZMQ: как выполнить привязку со стороны REP в сокет DEALER/REP или REQ/REP
Я хочу настроить топологию, в которой IP-адрес рабочего неизвестен, но известен только адрес центрального брокера. Таким образом, я пытаюсь связать с дилером и связаться с представителем. Но представитель никогда не получает мои сообщения:...
766 просмотров
schedule
06.12.2022
Как использовать zmq внутри функции (неблокирующим образом), чтобы получить состояние функции по запросу клиента?
Как использовать ZMQ неблокирующим образом, чтобы «обслуживать» статус долго выполняющегося задания, когда статус запрашивается клиентом?
В приведенном ниже коде показано, как длительная задача может быть временно «прервана» для отправки текущего...
720 просмотров
schedule
02.02.2023
Подписчик ZeroMQ не получает никаких данных в модульном тесте. Почему?
Я не понимаю, где заканчиваются мои данные.
Я написал тест, чтобы убедиться, что мой класс Publisher успешно отправляет данные и что эти данные будут получены, если я свяжусь с ним.
Сам класс наследуется от Thread и предоставляет метод...
725 просмотров
schedule
14.12.2022
Модель PUB/SUB pyzmq не получает сообщения внутри многопроцессорной обработки. Процесс
Я пытаюсь использовать архетипы сокетов PUB/SUB pyzmq внутри области multiprocessing.Process :
У меня есть один подписчик:
import time
import collections
import zmq
context = zmq.Context()
socket = context.socket(zmq.SUB)...
207 просмотров
schedule
15.05.2023
Почему этот асинхронный код не останавливается?
В следующем фрагменте кода есть две сопрограммы для сервера и клиента. Клиентская сопрограмма имеет логику прерывания цикла while через 10 секунд, а сервер должен остановиться через 15 секунд.
Когда я запускаю скрипт, он не останавливается, в...
897 просмотров
schedule
28.05.2023
Как использовать транспорт inproc с pyzmq?
Я создал два небольших скрипта, имитирующих процедуру публикации и подписки с помощью pyzmq. Однако я не могу отправлять сообщения моему клиенту-подписчику, используя транспорт inproc . Я могу использовать tcp://127.0.0.1:8080 нормально, просто...
2221 просмотров
schedule
13.04.2022
Подписчик не получает сообщение, Pyzmq
Я пытаюсь опубликовать сообщение (это похоже на широковещательную рассылку при использовании сырых сокетов) в мою подсеть с известным портом, но на стороне подписчика сообщение не получено. Идея заключается в том, что IP-адрес первой машины не должен...
933 просмотров
schedule
12.06.2022
Преобразование строк в числа
Я строю робота и мне нужно управлять им удаленно. Я решил сделать это с помощью zeromq. Со своего компьютера (сервера) я отправлю координаты x и y роботу (клиенту). Поэтому мне нужно, чтобы сообщение было отправлено в виде чисел, чтобы я мог...
543 просмотров
schedule
05.09.2022
Как решить VisibleDeprecationWarning: zmq.eventloop.minitornado устарел?
Когда я использую iPython для запуска некоторых скриптов, у меня появляется следующее предупреждающее сообщение в iTerm:
/Users/###/anaconda3/lib/python3.6/site-packages/ipykernel/displayhook.py:12: VisibleDeprecationWarning:...
1144 просмотров
schedule
08.01.2023
