Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Repo info
Activity
  • Sep 15 10:29
    casabre edited #1327
  • Sep 15 10:27
    casabre opened #1327
  • Sep 13 20:50
    htrifol opened #1326
  • Sep 09 20:46
    zpincus edited #1325
  • Sep 09 20:45
    zpincus edited #1325
  • Sep 09 20:45
    zpincus edited #1325
  • Sep 09 20:45
    zpincus opened #1325
  • Aug 31 07:12
    HWiese1980 commented #1323
  • Aug 31 06:36
    FishEatingCat commented #1323
  • Aug 31 06:34
    FishEatingCat commented #1323
  • Aug 30 08:13
    topic2k opened #1324
  • Aug 30 07:43
    yhf597869822 commented #391
  • Aug 30 07:25
    HWiese1980 opened #1323
  • Aug 28 10:09
    Jeducious closed #1322
  • Aug 28 10:09
    Jeducious commented #1322
  • Aug 28 07:45
    Jeducious commented #1322
  • Aug 28 07:22
    Jeducious opened #1322
  • Aug 23 18:08
    alexeiz commented #1282
  • Aug 22 13:16
    minrk closed #1320
  • Aug 22 13:16
    minrk commented #1320
David Warde-Farley
@dwf
even more bizarre: a call of time.sleep(1e-6) in send_integers fixes it.
1e-7 and we're back to screwups
I'll try that.
pip install pyzmq builds zmq for you if it's not there, right?
Min RK
@minrk
yes
Do you have libzmq in /usr/local/lib?
David Warde-Farley
@dwf
I apparently do not have a /usr/local/lib on this machine.
so, no.
Min RK
@minrk
ok
David Warde-Farley
@dwf
Persists with pip'd pyzmq
seems to even get worse?!
zmq.zmq_version() == '4.1.2' now
time.sleep(1e-6) inside the send loop still fixes the problem though.
Min RK
@minrk
Maybe it is a 10.9 kqueue thing. I'm not sure.
Andriy Drozdyuk
@drozzy
Anyone can help me figure out how to do HTTP with ZMQ_STREAM socket? I have my question up on SO: http://stackoverflow.com/questions/33114758/http-server-in-zmq-or-how-to-handle-a-post-request-with-pyzmq?noredirect=1#comment54043820_33114758
Dmitry Odzerikho
@xdmiodz
Hi! Is that true that pyzmq doesn't play well with native asyncio event loops and it's always required to set a zmq.asyncio.ZMQEventLoop as the primary loop in asyncio? Otherwise I gets the following error
Invalid file object: <zmq.asyncio.Socket object at 0x7fe92674dee8>
Min RK
@minrk
Yes, you must use ZMQEventLoop.
Dmitry Odzerikho
@xdmiodz
Ok, thanks
Min RK
@minrk
Regular system calls like poll, select, etc. don't work with zmq sockets, so zmq_poll must be used instead.
That's all ZMQEventLoop does - swap out the system call for zmq_poll
Dmitry Odzerikho
@xdmiodz
BTW, aiozmq works well with native loops, but I prefer the pyzmq's API anyway :)
Min RK
@minrk
aiozmq uses the zmq.FD API, which is a very problematic edge-triggered system that is known to lose events under nontrivial load. That's why I didn't go that way.
This has been a longstanding issue, and the only real reason for pyzmq to need to install its own poller, so I proposed that libzmq upstream add a level-triggered FD (I don't have the C++ or FD-fu to do it myself). If that happens, the need for a custom poller will go away.
HAH! Sun
@omani
hi all
I want to implement a zmqstream with tornado ioloop per thread in my flask application
it seems that the ioloop always runs and uses the main thread (which is my flask app)
how can I have an ioloop within each thread?
I am spawning the threads with gevent.spawn()
Min RK
@minrk
This message was deleted
Jean Chassoul
@jchassoul
Hello!
just wondering if pyzmq can use the new resource property available on ZMTP 3.1
HAH! Sun
@omani
hi jean. there is still no resource implemented afaict
Jean Chassoul
@jchassoul
Yes I notice back then (= thanks for your message I'm using a great Erlang zmq implementation for that and of course pyzmq on this side of things and happy with the results <3 its going to be awesome when we also have resource implemented in Python!
I'm also really happy with the new socket types included on the last zeromq release can't wait for future me to play with them.
HAH! Sun
@omani
which socket type do you mean?
the radio/dish?
Jean Chassoul
@jchassoul
yes I for what I notice we have the final implementations of client/server abstractions to "replace" rep/router and req/dealer and the new radio/dish, etc patters
HAH! Sun
@omani
yes.
Jean Chassoul
@jchassoul
also the resource property available since ZMTP 3.1 is really, really, really powerful! I like that very much. (=
HAH! Sun
@omani
how do you know it is powerful if it is not implemented yet?
Jean Chassoul
@jchassoul
the @drozzy work on chumak the erlang implementation is incredible and clean, really beautiful code if you can said such of thing about code
Jean Chassoul
@jchassoul
that implementation support ZMTP 3.1 with the resource property available and excellent python + erlang examples.
HAH! Sun
@omani
can you provide a source/link pls?
Jean Chassoul
@jchassoul
HAH! Sun
@omani
I wonder why this hasn't implemented in pyzmq yet
Carlos Llamacho
@CMLL
hello pyzmq room
Jose Raffucci
@JoseRaffucci
Hello everyone, I have just started using zeromq/pyzmq with the draft socket types zmq_server and zmq_client. I noticed that when there is a message waiting for the zmq_server socket the event id returned is 3. It doesn't match any of the constants except for zmq_shared or zmq_queue, I just wanted to see if someone had some clarification for the event id returned.
Dev Aggarwal
@devxpy

Hello there!

I had some problems using the zmq PUB/SUB feature. Can someone please take a look that this question?

https://stackoverflow.com/questions/53287435/zmq-pub-sub-drops-messages-when-sleep-is-not-done-after-send

Thank you.

Søren Fuglede Jørgensen
@fuglede
I'm seeing a discrepancy between how zmq.PAIR is blocking on Windows and Linux; it's not clear to me what the expected behavior would be, but the discrepancy itself seems to suggest that something is off: https://stackoverflow.com/questions/55752288/receiving-zmq-messages-on-background-thread-fails-on-windows -- can anyone immediately see why this might be?
hyjiang7
@hyjiang7
Hi guys, I'm new to zmq. I have a client socket who is receiving data from the server socket. The client is totally unaware of what type of data is coming through. How can I check on the client side if the data is of json type or not?