Articles of zeromq

Latencia ZMQ con PUB-SUB (suscriptor lento)

He encontrado muchas preguntas sobre un tema similar, pero no me ayudaron a resolver mi problema. Utilizando : Linux Ubuntu 14.04 python 3.4 zmq: 4.0.4 // pyZMQ 14.3.1 TL; DR La cola del receptor en el zócalo SUB de ZMQ está creciendo indefinidamente incluso después de que se establezca HWM. Esto sucede cuando el suscriptor […]

Python ZeroMQ PUSH / PULL – ¿Mensajes perdidos?

Estoy tratando de usar python con zeroMQ en modo PUSH / PULL , enviando mensajes de tamaño 4 [MB] cada pocos segundos. Por alguna razón, si bien parece que todos los mensajes se han enviado, SOLO ALGUNOS de ellos parecen haber sido recibidos por el servidor. ¿Que me estoy perdiendo aqui? Aquí está el código […]

ZeroMQ: HWM en PUSH no funciona

Estoy tratando de escribir un script de servidor / cliente con un servidor que ventile las tareas y varios trabajadores que lo ejecuten. El problema es que mi ventilador tiene tantas tareas que llenaría la memoria en un instante. Intenté establecer el HWM antes de que se enlace, pero sin éxito. Simplemente sigue enviando mensajes […]

Enviando mensajes desde otros idiomas a un kernel de IPython

¿Alguien tiene alguna experiencia en la comunicación con núcleos de IPython desde fuera de Python? Si estuviera intentando enviar mensajes desde una aplicación de Python a un kernel IPython, usaría la API zmq.kernelmanager . Tal como está, obviamente necesitaré escribir mi propio administrador del kernel en otro idioma, pero no puedo encontrar la información que […]

¿Cómo utilizar los transportes inproc e ipc de Zeromq?

Soy un novato en ZERMQ. ZeroMQ tiene transportes TCP, INPROC e IPC. Estoy buscando ejemplos usando python e inproc en Winx64 y python 2.7, que también se podrían usar para Linux. Además, he estado buscando métodos de transporte UDP y no puedo encontrar ejemplos. El único ejemplo que encontré es import zmq import zhelpers context […]

El socket ZeroMQ PUB almacena todos mis datos cuando se está conectando

Noté que un zeromq PUB socket almacenará todos los datos salientes si se está conectando, por ejemplo import zmq import time context = zmq.Context() # create a PUB socket pub = context.socket (zmq.PUB) pub.connect(“tcp://127.0.0.1:5566”) # push some message before connected # they should be dropped for i in range(5): pub.send(‘a message should not be dropped’) […]

¿Cómo podría establecer hwm en el patrón de empujar / tirar de zmq?

He encontrado una pregunta similar, ZeroMQ: HWM en PUSH no funciona , pero no pudo resolver mi problema. Quiero controlar la cantidad de mensajes que el socket de inserción pone en cola, pero no funciona y aún así pone en cola 1000 mensajes. Así que quiero saber cómo configurar el hwm del zócalo de inserción. […]

Error al instalar ZeroMQ

Traceback (most recent call last): File “”, line 1, in File “/usr/local/lib/python2.7/dist-packages/zmq/__init__.py”, line 51, in from zmq import core, devices File “/usr/local/lib/python2.7/dist-packages/zmq/core/__init__.py”, line 26, in from zmq.core import (constants, error, message, context, ImportError: /usr/local/lib/python2.7/dist-packages/zmq/core/socket.so: undefined symbol: zmq_sendmsg Me estoy poniendo por encima del error. He seguido los pasos dados en el sitio oficial de ZeroMQ.

Punto muerto al sincronizar dos scripts de python3 simples usando 0mq (ZeroMQ)

Obtengo este extraño interlocking cuando bash sincronizar dos scripts de python3 usando 0mq ( ZeroMQ ). Los scripts se ejecutan bien durante varios miles de iteraciones, pero tarde o temprano ambos se detienen y se esperan el uno al otro. Estoy ejecutando ambos scripts de diferentes CMD-Windows en Windows 7. No puedo entender ¿Por qué […]

0mq: ¿La latencia de pubsub crece continuamente con mensajes?

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 True: msgdata = time.time() socket.send(“%d %d” % (topic, msgdata)) print “topic:%d, msg:%.5f” % (topic, msgdata) time.sleep(1) sub.py import sys import zmq import […]