Вопросы по теме 'pyzmq'
Python не может импортировать zmq даже после установки pyzmq
Я установил zmq и pyzmq на Ubuntu 10.10, и все прошло нормально.
import zmq я получаю сообщение об ошибке,
с указанием " ImportError: cannot import name initthreads "
Кто-нибудь может сказать мне, почему это происходит?
5229 просмотров
schedule
26.02.2023
Подключение к удаленному экземпляру IPython
Я хотел бы запустить экземпляр IPython на одном компьютере и подключиться к нему (по локальной сети) из другого процесса (для запуска некоторых команд Python). Я понимаю, что это возможно с zmq:...
26201 просмотров
schedule
04.05.2022
Как установить тайм-аут очереди сокета pyzmq
Я подключил zeromq, «msg_in» уже стоял в очереди. Если за указанный период времени нет нового сообщения, очередь ставится на истечение времени ожидания. как установить таймаут. Ниже приведен основной код
requestDict = {"id":111, "name":"test"}...
4119 просмотров
schedule
28.07.2023
Какой шаблон ZeroMQ лучше всего подходит для асинхронной пары сокетов?
У меня есть сервер (работает на Amazon) и один клиент, который к нему подключается. После установления соединения клиент и сервер взаимодействуют исключительно друг с другом и отправляют сообщения.
e.g.
1. Client -> Server
2. Client ->...
2340 просмотров
schedule
02.09.2023
Невозможно импортировать zmq в python (проблема с установкой)
Я не могу установить pyzmq на свой macbook (OSX 10.9.1)
Первый вызов должен был запустить:
sudo pip install pyzmq
Произошла ошибка, что libzmq не удалось найти, и, похоже, он попытался скомпилировать версию в комплекте:
jono@air:~ $...
12956 просмотров
schedule
08.10.2022
Всякий раз, когда обработчики выполняются, нужно отправить сообщение в zeromq, оно остается висящим.
У меня есть nginx перед 8 экземплярами Tornado, и для некоторых запросов (обработчик комментариев) мне нужен Tornado для отправки сообщений на ZeroMQ. Я делаю это в конце обработчика (непосредственно перед отправкой ответа клиенту):
# here is...
128 просмотров
schedule
31.10.2022
ZeroMQ pyzmq отправляет изображение в формате jpeg через TCP
Я пытаюсь отправить файл изображения jpeg через соединение ZeroMQ с pyzmq, но результат в 3 раза превышает размер ввода и больше не является допустимым jpeg. Я загружаю изображение и отправляю с...
f = open("test1.jpg",'rb')
strng = f.read()...
5812 просмотров
schedule
29.01.2023
0mq: задержка pubsub постоянно растет вместе с сообщениями?
pub.py
import zmq
import random
import sys
import time
port = "5556"
if len(sys.argv) > 1:
port = sys.argv[1]
int(port)
context = zmq.Context()
socket = context.socket(zmq.PUB)
socket.bind("tcp://*:%s" % port)
topic = 10001
while...
369 просмотров
schedule
02.02.2023
Случайное зависание/зависание в Python ZeroMQ
Я пишу сбалансированный клиент-рабочий сервис без брокера, написанный на python с помощью ZeroMQ .
Клиенты получают адрес работника, устанавливают соединение ( zmq.REQ / zmq.REP ), отправляют один запрос, получают один ответ и затем...
1325 просмотров
schedule
24.05.2023
Zeromq, какой сокет должен связываться с шаблоном PubSub
Я читал о ZeroMQ, в частности о NetMQ, и почти все примеры Pub/Sub, которые я видел, использовались для привязки сокета издателя, а затем сокет подписчика подключался к другому.
Поэтому мне интересно, можно ли сделать обратное, я имею в виду...
1191 просмотров
schedule
05.09.2022
Сокет PyZMQ не может быть отправлен при создании в функции
С PyZMQ, когда я пытаюсь создать сокет внутри функции и отправить с ним сообщение, сообщение никогда не будет получено.
context = zmq.Context()
def sender():
sock = context.socket(zmq.PUB)...
118 просмотров
schedule
23.03.2023
ImportError: невозможно импортировать константы имен
Я пытаюсь запустить простой фрагмент кода с помощью pyzmq. Я использую Python 2.7 и pyzmq 14.5.
$ python --version
Python 2.7.6
$ sudo find /usr -name "*pyzmq*"
/usr/local/lib/python2.7/dist-packages/pyzmq-14.5.0.egg-info...
25352 просмотров
schedule
19.09.2022
Подходящий шаблон сообщений Zmq для взаимодействующих процессов
Я использую библиотеку pyzmq для установления связи между двумя процессами Python на одном компьютере. Глядя на доступные шаблоны обмена сообщениями, предлагаемые ZMQ, неясно, какой из них подходит. В моем случае оба процесса должны отправлять...
191 просмотров
schedule
14.03.2024
Циклический перебор zmq потерял сообщение PUSH/PULL
Пытаюсь отправить 10 сообщений с одного клиента на двух рабочих. Я использую модель PUSH/PULL. Я теряю сообщение на 2.
python push.py
message n°0
message n°1
message n°2
message n°3
message n°4
message n°5
message n°6
message n°7
message n°8...
371 просмотров
schedule
13.12.2022
Размер буфера ZeroMQ по сравнению с максимальной отметкой
В zeromq параметрах сокета у нас есть флаги как для максимальной отметки, так и для размер буфера.
Для отправки это ZMQ_SNDHWM и ZMQ_SNDBUF .
Кто-нибудь может объяснить разницу между ними?
3994 просмотров
schedule
19.03.2023
Установите идентификатор для нескольких серверов ZMQ, привязанных к одному и тому же порту.
Я реализую шаблон ZMQ DEALER-ROUTER в Python 3.4. Этот код из руководства ZMQ является ядром моей программы. Он легко устанавливает идентификатор для каждого клиента (например, 1,2,3,4). Однако, если я запускаю такое же количество рабочих...
961 просмотров
schedule
27.11.2022
Pyzmq - отправить сообщение в сокет STREAM
Я пытаюсь реализовать простой пример соединения между двумя сокетами STREAM в pyzmq.
sender.py
import zmq
context = zmq.Context()
socket = context.socket(zmq.STREAM)
socket.bind("tcp://*:5555")
socket.connect("tcp://localhost:5556")...
1682 просмотров
schedule
19.11.2022
Каковы допустимые флаги ZeroMQ .recv()?
В pyzmq Socket.recv_pyobj можно указать необязательный параметр int flags , который может быть «любым допустимым флагом .recv() ». К сожалению, я не могу найти никаких ссылок на то, что на самом деле представляют собой эти флаги.
Итак,...
982 просмотров
schedule
29.06.2022
Пользовательский ввод PyZMQ() в коммуникационном архетипе PAIR/PAIR
Я использую PyZMQ для создания простого шаблона обмена сообщениями PAIR/PAIR.
Парный сервер
import zmq
import random
import sys
import time
port = "9999"
context = zmq.Context()
socket = context.socket(zmq.PAIR)
print("Binding socket to port:...
344 просмотров
schedule
13.01.2023
Как установить INVERT_MATCHING на сокет ZeroMQ PUB с помощью PyZMQ?
Я работаю с PyZMQ 16.0.4 при поддержке ZeroMQ 4.1.6 и пытаюсь лучше понять параметр сокета INVERT_MATCHING .
Я пробовал следующее в repl:
>>> import zmq
>>> context = zmq.Context.instance()
>>> pubsock =...
89 просмотров
schedule
31.10.2022
