Articles of zeromq

No se puede importar zmq en python (problema de instalación)

Parece que no puedo instalar pyzmq en mi macbook (OSX 10.9.1) La primera llamada fue para ejecutar: sudo pip install pyzmq Hubo un error que no se pudo encontrar libzmq, y pareció que intentaba comstackr la versión incluida: jono@air:~ $ sudo pip install pyzmq Password: Downloading/unpacking pyzmq Downloading pyzmq-14.0.1.tar.gz (867kB): 867kB downloaded Running setup.py egg_info […]

El zócalo de inserción ZeroMQ hace que el cliente no finalice cuando no hay proceso de escucha

Estoy empezando a meterme con ZeroMQ y tengo un problema con un cliente que no termina normalmente. En particular, tengo un cliente que puede “enviar” datos cuando no hay un servidor receptor escuchando y eso parece hacer que el proceso se bloquee una vez que el código de Python haya terminado. Supongo que hay un […]

¿Cómo borro el búfer al iniciar / salir en el zócalo ZMQ? (para evitar que el servidor se conecte con clientes muertos)

Estoy usando un socket de tipo REQ / REP para la comunicación ZMQ en python. Hay varios clientes que intentan conectarse a un servidor. Se han agregado tiempos de espera en el script del cliente para evitar una espera indefinida. El problema es que cuando el servidor no se está ejecutando, y un cliente intenta […]

¿Cómo ejecutar un zmq y otro mientras que True: al mismo tiempo de forma independiente?

Tengo este código para mi servidor: import time import zmq context = zmq.Context() socket = context.socket(zmq.REP) socket.bind(“tcp://*:5000″) while True: message = socket.recv() socket.send(b”World”) print “sent” while True: print “done.” Tengo un script de cliente separado que envía un mensaje a través de zmq a este cada vez que envío un mensaje. En el servidor (este […]

¿Cómo puedo usar send_json con pyzmq PUB SUB?

Necesito enviar un diccionario como mensaje de un editor a los suscriptores. Con el patrón REQ / REP send_json y recv_json funcionan bien, pero parece que no puedo encontrar un conjuro que funcione para PUB / SUB Espero que no sea el caso que PUB / SUB solo pueda trabajar con send () y recv […]

zero-mq: socket.recv () call está bloqueando

Estoy tratando de usar zero-mq. Mi requisito es muy simple. Quiero poder comunicarme entre dos pares en una red. Encontré este progtwig en los ejemplos del libro. $ pub_server.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” […]

Python zeromq – ¿Editores múltiples para un solo suscriptor?

Me gustaría escribir un script en python (llámelo padre ) que haga lo siguiente: (1) define una matriz numpy multidimensional (2) forks 10 scripts de python diferentes (llámalos hijos ). Cada uno de ellos debe poder read el contenido de la matriz numpy desde (1) en un momento dado (siempre que estén vivos). (3) cada […]

¿Hay un ejemplo de cliente Spyne?

Estoy tratando de usar spyne ( http://spyne.io ) en mi servidor con ZeroMQ y MsgPack. He seguido los ejemplos para progtwigr el servidor, pero no puedo encontrar ningún ejemplo que me ayude a saber cómo progtwigr el lado del cliente. He encontrado la clase spyne.client.zeromq.ZeroMQClient, pero no sé qué se supone que es el parámetro […]

ZMQ: No hay mensaje de suscripción en el socket XPUB para múltiples suscriptores (patrón de caché de último valor)

Implementé el ejemplo de Last Value Caching (LVC) de ZMQ ( http://zguide.zeromq.org/php:chapter5#Last-Value-Caching ), pero no puedo obtener un segundo suscriptor para registrarse en el backend. La primera vez que se incorpora a un suscriptor, se event[0] == b’\x01′ condición event[0] == b’\x01′ y se envía el valor almacenado en la event[0] == b’\x01′ caché, pero […]

No se pueden obtener los enlaces de Python de ZeroMQ para recibir mensajes a través de IPC

Estoy tratando de lograr PUB / SUB sobre IPC. Si cambié el código a continuación para que el suscriptor se enlace a “tcp: // *: 5000” y el editor se conecte a “tcp: // localhost: 5000”, funciona, pero no puedo hacer que funcione a través de IPC. ¿Qué estoy haciendo mal? suscriptor.py import zmq, json […]