Tagged Questions
0
votes
1answer
26 views
Communicate between a C++ plugin and a Python program
I'm having so many doubts about this that i thought i should ask. Here's the situation:
I'm writing a C++ .dll that is going to be loaded into a program,"EuroScope.exe". While loaded, the program ...
0
votes
1answer
16 views
Why is this implementation of push/pull in zeromq not returning all messages
I have a client server pair in zeromq. What is strange is that the pull client only receives only every other message sent. Here is my implementation
## Push Server
import zmq
def post():
...
1
vote
1answer
43 views
Sharing data using pyzmq zero-copy
I stumbled on zeromq when searching for an efficient solution to IPC in python; I have a couple of python processes which need to do some cpu intensive processing on data from a dict in a master ...
0
votes
1answer
36 views
How to wrap a zeromq bind socket in a twisted application service?
I am using txzmq and twisted to build a listener service that will process some data through a push-pull pattern. Here's a working code:
from txzmq import ZmqFactory, ZmqEndpoint, ZmqPullConnection
...
0
votes
1answer
24 views
Termination of python script when using zeromq with dead server
I have a problem in closing python application when i using zeromq.
first i connect to a server that is not running!
context = zmq.Context()
socket = context.socket(zmq.REQ)
socket_id = randomID()
...
1
vote
1answer
44 views
ZMQ and Twisted
I'm trying to do something seemingly simple, but I'm not sure how to go about it...
I have an application that publishes messages over a ZMQ PUB socket. I'd like to write a small server that ...
1
vote
1answer
70 views
processing HTTPS requests and ZeroMQ messages in parallel inside Twisted
I am trying to do two things in parallel:
intercept HTTPS POST request and make Twisted hold the connection open indefinitely (return NOT_DONE_YET)
listen to ZeroMQ queue (and close one of the ...
0
votes
3answers
121 views
Trying to send simple messages with zeromq in python between two hosts
Script running on machine 1
$ cat foo.py
import zmq
context = zmq.Context()
socket = context.socket(zmq.SUB)
socket.bind("tcp://127.0.0.1:5000")
print "socket bound"
while True:
print ...
1
vote
0answers
116 views
a good way to use tornado with zeromq
I'm trying to achieve a link between tornado and zmq asynchronously.
i've manage to code something that works like that :
sub=context.socket(zmq.SUB)
class market(RequestHandler):
@asynchronous
...
1
vote
1answer
99 views
Python hangs up on returning from a function
So say I have two functions in a fairly complicated Flask application. One function calls the other function.
def dispatch_unlock(...):
# ... stuff ...
log('dis start')
# this routine ...
1
vote
2answers
70 views
Data obtaining check PUB/SUB pattern
There is a server, that collects some data and then sends it to the client. I need to be sure that the client got the data sent by server. I thought PUB/SUB pattern here would be best choice, but I ...
1
vote
1answer
100 views
Sending messages from other languages to an IPython kernel
Does anyone have any experience of communicating with IPython kernels from outside of Python?
If I were trying to send messages from a Python app to an IPython kernel, I'd use the zmq.kernelmanager ...
3
votes
1answer
56 views
Pub/ Sub - Subscribing to a non-0MQ publisher
I'm currently trying to make a proxy with 0MQ. I would like to subscribe to a publisher that is not running under 0MQ. I mean I have the address and the port of a distant publisher that is sending XML ...
2
votes
1answer
74 views
Lazy Pirate pattern with real request data
I am learning zmq with PyZMQ binding and i have trouble with Lazy Pirate pattern.
So, here is a code for Lazy Pirate server and Lazy Pirate client.
In example client sends request, but it is simple ...
0
votes
1answer
30 views
why is easy_install using python 2.6 for zeromq binding installation?
sudo easy_install pyzmq
Searching for pyzmq
Best match: pyzmq 13.0.2
Processing pyzmq-13.0.2-py2.6-macosx-10.8-intel.egg
pyzmq 13.0.2 is already the active version in easy-install.pth
Using ...
1
vote
1answer
111 views
no module named zmq for python code
When I try to run this script
# -*- coding: utf-8 -*-
#
# Hello World client in Python
# Connects REQ socket to tcp://localhost:5555
# Sends "Hello" to server, expects "World" back
#
import ...
0
votes
0answers
71 views
Reconnecting to ZMQ feed after disconnect
I have this simple python script which connects to a ZMQ feed and spits out some data:
#!/usr/bin/env python2
import zlib
import zmq
import simplejson
def main():
context = zmq.Context()
...
3
votes
1answer
143 views
Implement zeromq publisher in django with celery (Broker redis)
i need to implement zmq publisher in django and celery with redis as a broker. But my client doesn't receive anything.
tasks.py
from celery import task
import zmq
try:
context = ...
0
votes
1answer
139 views
ZeroMQ + Django & uwsgi issues
Using django, we need to send a message to another, separate python program.
Zeromq seems to be lightweight and should fit the bill for this.
However, trying to get it to work and it always ends up ...
1
vote
2answers
121 views
pyzmq create a process with its own socket
I have some code thats monitoring some other changing files, what i would like to do is to start that code that uses zeromq with different socket, the way im doing it now seems to cause assertions to ...
0
votes
1answer
82 views
Multiple ipc publishers and one subscriber using python-zmq
I'm wondering if is possible set multiple ipc publishers for one subscriber using zmq ipc...
Abstractly I have only one publisher like this, but I need run multiple instances of it getting several ...
0
votes
0answers
97 views
ZeroMQ -> Excel RTD server .. Is it that difficult?
I am just starting with zeromq. I've got various platforms / languages all talking to each other nicely now and I must admit - it does a really good job.
The last piece of the jigsaw I'd like to do ...
0
votes
0answers
28 views
Communication bridge between different users
I need to create some "queue system" (sorry, don't actually know how to call this). The idea is
User A have one process up and running
User B need to send a queue to the A's process, to instruct it ...
1
vote
1answer
110 views
How to integrate zeromq polling into pyqt main loop?
I've got a simple PySide program (my first GUI program) in which I just have two sliders going from -100 to 100. The first slider sends its value to a hardware controller using zeromq. This controller ...
0
votes
1answer
61 views
Best way to distributed massive ammounts on zip files
I haven't much experience in distributed computing, but I would like to create a script within python to distribute unzip jobs centrally to x amount of servers, saving me from the hassle of routinely ...
0
votes
1answer
136 views
How to take action if ZeroMQ doesn't receive messages?
I've got some sort of distributed control system in which I send a heart beat every second. On the receiving end I need to take action if no message has been received for more than 2 seconds. The ...
3
votes
2answers
476 views
Does zeromq support IPC as a transport channel on windows?
I get the following error message, when I try the router example wiht python on Windows (Windows 8):
Traceback (most recent call last):
File "router.py", line 43, in <module>
...
0
votes
1answer
89 views
Is there a way to make ZeroMQ work on one socket for all incoming/outgoing message patterns?
Zmq is really fast yet have pair of sockets for each 2 way connection (and for each connection type - such as REQ-REQ and PUB-SUB etc) on each side is a pain for any complex architecture. And so a ...
1
vote
1answer
647 views
Websockets behind nginx triggered by zeromq?
I'm trying to design a system that will process large amounts of data and send updates to the client about its progress. I'd like to use nginx (which, thankfully, just started supporting websockets) ...
3
votes
1answer
56 views
0MQ in virtualenv
I was able to install 0MQ in Ubuntu 12.04 by doing the followinng:
$ sudo apt-get install libzmq-dev
$ sudo apt-get install python-zmq
but when I went to use it in a virtualenv it could not ...
