How to use Zeromq's inproc and ipc transports?

Im a newbie to ZERMQ. ZeroMQ has TCP, INPROC and IPC transports. I'm looking for examples using python and inproc in Winx64 and python 2.7, which could also be used for linux. Also, I have been...

Detecting when ZMQ_RATE limit or ZMQ_SNDHWM have been reached

Is there a way to programatically know when a pgm zeromq socket has stopped forwarding information because the ZMQ_RATE limit has been reached or if it is dropping data because the ZMQ_SNDHWM...

difference between pub-sub and push-pull pattern in zeroMq

This two images are from http://zguide.zeromq.org/page:all. What is the difference between this two pattern if we ignore sink in push-pull pattern ? Is there a difference in how a message gets...

how do I get a ZMQ Router to raise an error if it is busy?

I've got a REQ -> ROUTER -> [DEALER,DEALER... DEALER] setup going where REQ is a client, ROUTER is a queue and the DEALER sockets are workers that process data and send it back to ROUTER which...

zeromq and python multiprocessing, too many open files

I have an agent-based model, where several agents are started by a central process and communicate via another central process. Every agent and the communication process communicate via zmq....

ImportError: cannot import name constants

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...

Interrupting Flask app in iPythonNotebook cause ZMQerror

I'm trying to run a most simple demo of flask app in an iPython notebook like this. from flask import Flask app = Flask(__name__) @app.route('/') def hello_world():. return 'Hello World!' if...

Python threading queue is very slow

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...

What is a simple example of a working XSUB / XPUB proxy in zeromq

I have a follow-up to https://stackoverflow.com/questions/18570810/how-to-implement-pub-sub-network-with-a-proxy-by-using-xpub-and-xsub-in-zeromqc That question requested a C++ proxy using XSUB...

ijavascript will not install

I have been trying to run Javascript from a Jupyter Notebook on Windows 10 but failed miserably. It seems I cannot install IJavascript to make it available. All installation guides say to use...

What is the difference between using ZMQ PUB with .connect() or .bind() methods?

In Python ZMQ publisher/subscriber sample template, the publisher uses .bind() method and the subscriber uses .connect() method, that connected to the bind IP address. But we can replace .bind()...

How to send integer values between server and client using zeromq(zmq)?

I have a C++ server and client code with zmq ( ZeroMQ ) lib. I would like to send integer values to the client. I have read through the manual for zmq, but I have a problem sending anything else...

Async ZeroMQ for nim

I have never used ZeroMQ and first heard of it an hour ago. But from the guide (this guide) it sounds like there are async I/O. It also happens that there is a nim port : this one So I was...

How run composer install from dockerfile in php container

Good day I have php container which seting up in Dockerfile I am trying to run composer install with this command WORKDIR '/app' RUN curl -sS https://getcomposer.org/installer | \ php...

Python: why do I get an error when I import geopandas?

I try to import geopandas in my jupyter notebook. import geopandas as gp and I get the following error: ImportError:...

WEBP support not installed error with Pillow included in Anaconda

I have written a small code to open webp image in the Anaconda prompt. from PIL import Image im = Image.open('test.webp') It causes the following...

Zero-Copy messaging with zmqpp

ZeroCopy messaging is something that can be implemented in zeromq, but is it possible to use it with the zmqpp c++ bindings? There is almost no documentation, and I was not able to find anything...

Use zmq.Poller() to add timeout for my REQ/REP zmqclient, but the function does not return anything

I want to add a timeout for my 0MQ client. I tried zmq.Poller(). It seems to work at the beginning. But when I move code into a function, I find it doesn't return anything. It just stuck there. I...

Python ZMQ responder not receiving message

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 =...

"AssertionError: Torch not compiled with CUDA enabled" in spite upgrading to CUDA version

I figured out this is a popular question, but still I couldn't find a solution for that. I'm trying to run a simple repo Here which uses PyTorch. Although I just upgraded my Pytorch to the latest...

How can i write my own RPC Implementation for Protocol Buffers utilizing ZeroMQ

According to the Google Protocol Buffers documentation under 'Defining Services' they say, it's also possible to use protocol buffers with your own RPC implementation. To my understanding,...

ImportError: cannot import name 'rcParams' from 'matplotlib'

I have tried to uninstall and reinstall matplotlib in my tf-gpu enviornment I made but I keep getting this error: ImportError: cannot import name 'rcParams' from 'matplotlib' This is the entire...

Go: using gob with zmq4

I'm trying to use gob with a zmq4 socket (from pebbe's zmq4). A zmq4 socket does not have an io device making it seemingly impossible for gob to read/write directly: I cannot use &client ( type...

How to receive images from Raspberry Pi over ZeroMQ PUB/SUB in Python?

I want to send images taken by Picamera on Raspberry Pi to my windows computer. I wrote some code, as follows (they are simplified here), but it gets stuck in frame = footage_socket.recv_string()...

zeromq.js - Await connection

The documentation for connect method says, Connects to the socket at the given remote address and returns immediately. The connection will be made asynchronously in the background. But, await...

ZeroMQ: very high latency with PUSH/PULL

Summary I see very high latency at the receiver using `zmq.PUSH/PULL` sockets. Details I'm new to ZeroMQ, and am trying to send a few MBytes from the sender to the receiver (my final aim is to...

How to make ZeroMQ use UDP?

I can't seem to be able to use UDP or find any examples of how to use it in PyZMQ. I want to be able to send a h264 stream. I was able to do that using TCP by using @nathancy answer on Python...

Installing Kotlin-Jupyter: e: java.lang.NoClassDefFoundError: Could not initialize class org.jetbrains.kotlin.com.intellij.pom.java.LanguageLevel

I'm new to gradle, but recently I wanted to use Kotlin-Jupyter notebook for a project. I followed the instructions, I cloned the repo at https://github.com/Kotlin/kotlin-jupyter... Throughout my...

Getting DLL error when running tensorflow/keras program on python gpu 3.8

I am trying to run my simple AI program but I keep getting this DLL error: ImportError: Could not find the DLL(s) 'msvcp140_1.dll'. TensorFlow requires that these DLLs be installed in a...

Jupyterlab unresponsive after launching it from within a docker container

I am trying to create some python code using a Jupyter Lab instance running within a docker container. I have been able to successfully create the Dockerfile to accomplish the same and launch...