I am unable to use Jupyter notebooks on VS Code within a virtual environment, due to a problem with installing ipykernel. When I switch to the global environment, ipykernel installs fine and I can ...

I got this error in my program: Traceback (most recent call last): File "scriptA.py", line 17, in <module> socketPub.bind("tcp://localhost:%s"% portPub) File "socket.pyx", line 434, in zmq.b...

I acquire samples (integers) at a very high rate (several kilo samples per seconds) in a thread and put() them in a threading.Queue. The main thread get()s the samples one by one into a list of len...

I'm trying to run a simple piece of code using pyzmq. I am using Python 2.7 and pyzmq 14.5 $ python --version Python 2.7.6 $ sudo find /usr -name "*pyzmq*" /usr/local/lib/python2.7/dist-p...

I tried everything but pyzmq package is not installing. It stops while trying wheel. I even reinstalled wheel but no result. I have already installed all basic prereq stuff. I even installed cla...

I am surprised this has not really been asked in detail but for some reason i could not find this question or solution anywhere. It seems to be that a lot of people are having a problem where...

I have a container with the python:3.6-alpine kernel. I have a problem installing the pyzmq via pip on this: Dockerfile: FROM python:3.6-alpine RUN mkdir /code RUN apk add vim WORKDIR / ADD . /cod...

please see the code below : server.py import zmq import time from multiprocessing import Process class A: def __init__(self): ctx = zmq.Context(1) sock = zmq.Socket(ctx, zmq.PUB) sock.bind('i...

I am trying to get a python program to communicate with another python program via zeromq by using the request-reply pattern. The client program should send a request to the server program which re...

I am trying to send a jpeg image file through a ZeroMQ connection with pyzmq, but the output is 3 times the size of the input, and no longer a valid jpeg. I load the image and send with... f = ope...

I am trying to create a real life system where an action needs to be performed by the subscriber on real-time data provided by the publisher. Sometimes the PUB and SUB get out of sync(by up to 10 s...

I am trying a simple zmq script but somehow the responder is not getting the first message. The Responder looks like this: def main(): context = zmq.Context() socket = context.socket(zmq.REP) ...

I've been following this (https://developer.ibm.com/tutorials/se-distributed-apps-zeromq-part2/) tutorial for setting up a ZeroMQ client/server setup which uses CurveZMQ to encrypt messages. The co...

I tried to monitor the number of open Unix socket files with lsof -U | wc -l while I executed this code: >>> import zmq # 1375 Unix socket files >>> c = zmq.Context() # 1377 Unix...

I know how to send a string message from c++ to python via zeromq. Here's the code for sending a string message I know : C++ sender code : void *context = zmq_ctx_new(); void *publisher = zmq_s...

I have a number of nodes that will use a secondary service to be informed about the address of each other. I want to be able to publish information so as all the other nodes can hear it. Using an X...

Can someone point me to an example of a REQ/REP non-blocking ZeroMQ (0MQ) with Python bindings? Perhaps my understanding of ZMQ is faulty but I couldn't find an example online. I have a server in ...

For sending string data, following codes works : context = zmq.Context() socket = context.socket(zmq.PUB) socket.bind("tcp://*:5667") socket.send_string("my string data") For sending image(ndar...

According to the ZeroMQ documentation a pub socket is supposed to drop messages once the number of queued messages reaches the high-water mark. This doesn't seem to work in the following example (...

I want to limit the amount of memory consumed by my ZeroMQ message queues in a Python application. I know that setting the high-water mark will limit the amount that will be queued on the sender si...

I have a container that it has several ports, I want to have access to one of its ports (9001) outside of this docker as remote. My docker IP is: 172.17.0.1 My container IP is: 172.19.0.23 My ser...

I am trying to use the ZeroMQ rep/req and cannot figure out how to handle server side errors. Look at the code from here: socket.bind("tcp://*:%s" % port) while True: # Wait for next request fro...

N-proxy-N Pub-Sub Similar to the question N to N async pattern in ZeroMQ?, but which unfortunately never received an answer with working code. I'm trying to implement Pub-Sub network as described...

I've just started with ZeroMQ and I'm trying to get a Hello World to work with PyZMQ and asyncio in Python 3.6. I'm trying to de-couple the functionality of a module with the pub/sub code, hence th...

I'm trying to use ZeroMQ in Python (pyzmq) together with multiprocessing. As a minmal (not) working example I have a server- and a client-class which both inherit from multiprocessing.Process. The ...