Hola a todos, tengo una duda con zmq...
Tengo un servicio que está publicando datos mediante el modelo ipc de zmq
context = zmq.Context()
publisher = context.socket(zmq.PUB)
publisher.connect("ipc://VCserver")
myjson = json.dumps(worker.data)
publisher.send(myjson)
y otro servicio(subscriber) que revisa los datos para generar ciertas alertas...
context = zmq.Context()
subscriber = context.socket(zmq.SUB)
subscriber.bind("ipc://VCserver")
subscriber.setsockopt(zmq.SUBSCRIBE, '')
while True:
response = subscriber.recv()
if response:
data = json.loads(response)
check(data)
Ahora debo implementar múltiples instancias publishers y
no tengo bien claro si se podrá usando un solo subscriber o deberé implementar
las instancias cada una, pareada con su propio subscriber, como la comunicación
se realiza a través de un archivo especial, me queda la duda.
Las instancias Publisher toman distintos tipos de datos, por lo que no
son siempre iguales
pero el subscriber siempre realiza las mismas tareas, como conectarse
a una bd e
insertar datos.
Bueno, desde ya muchas gracias.
Christian.
_______________________________________________
Python-es mailing list
Python-es@python.org
http://mail.python.org/mailman/listinfo/python-es
FAQ: http://python-es-faq.wikidot.com/
