Articles of zeromq

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 […]

ZeroMQ y múltiples filtros de suscripción en Python

Me gustaría suscribirme a varios filtros con ZeroMQ en Python, usando un socket. sock.setsockopt(zmq.SUBSCRIBE, ‘first.filter’) sock.setsockopt(zmq.SUBSCRIBE, ‘second.filter’) Pero esto no funciona. Solo se toma en cuenta el primero. Sin embargo, leí esto en el sitio zeromq : Se pueden adjuntar múltiples filtros a un solo zócalo ZMQ_SUB , en cuyo caso se aceptará un mensaje […]

¿Cómo enviar secuencias de video OpenCV a través de sockets ZeroMQ?

Tengo una cámara web simple que leo con OpenCV y ahora estoy tratando de enviar este video a un progtwig diferente (Python) usando ZeroMQ . Así que tengo el siguiente script simple para leer la cámara web y enviarla utilizando un socket ZeroMQ: import cv2 import os import zmq import base64 context = zmq.Context() footage_socket […]

El socket PUSH PyZMQ no se bloquea en el envío ()

La sección ZMQ_PUSH en la documentación del zócalo ZMQ dice que llamar a send() en el zócalo PUSH, que no tiene nodos descendentes debe bloquearse hasta que al menos un nodo esté disponible. Sin embargo, la ejecución del siguiente código no parece bloquear en send() . Además, el proceso no se cierra hasta que ejecuto […]

Python Multi-Processing Question?

Tengo una carpeta con 500 archivos de entrada (el tamaño total de todos los archivos es ~ 500 [MB]). Me gustaría escribir un script en python que haga lo siguiente: (1) cargar todos los archivos de entrada en la memoria (2) inicializa una lista de python vacía que se utilizará más adelante … ver viñeta […]

Zeromq con python se bloquea si se conecta a un socket no válido

Si me conecto a un socket inexistente con pyzmq, necesito presionar CTRL_C para detener el progtwig. ¿Podría alguien explicar por qué sucede esto? import zmq INVALID_ADDR = ‘ipc:///tmp/idontexist.socket’ context = zmq.Context() socket = context.socket(zmq.REQ) socket.connect(INVALID_ADDR) socket.send(‘hello’) poller = zmq.Poller() poller.register(socket, zmq.POLLIN) conn = dict(poller.poll(1000)) if conn: if conn.get(socket) == zmq.POLLIN: print “got result: “, socket.recv(zmq.NOBLOCK) […]

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 […]