streamz icon indicating copy to clipboard operation
streamz copied to clipboard

Any support for RabbitMQ ?

Open Niloy-Chakraborty opened this issue 5 years ago • 4 comments

I have RabbitMQ and I need to feed the streaming data for parallel execution. So,I opted RabbitMQ-> Streamz -> Dask for this purpose. But I am facing problems for Rabbit-Streamz integration. Any suggestions/solutions for this ?

Niloy-Chakraborty avatar Aug 26 '19 00:08 Niloy-Chakraborty

What problems are you facing? The approach I took with ZMQ was to use a dispatcher which called source.emit when new data was sent over.

CJ-Wright avatar Aug 26 '19 00:08 CJ-Wright

I am newly applying the concepts of Message Queue and Streaming for my work. So I am not getting how to consume the data using Streamz, from RabbitMQ

Niloy-Chakraborty avatar Aug 26 '19 00:08 Niloy-Chakraborty

@CJ-Wright , could you please explain little more, if possible through code...It would be of great help.

Niloy-Chakraborty avatar Aug 26 '19 00:08 Niloy-Chakraborty

Here is a short sketch.

  1. Have a system which receives data and calls a function when that data is obtained, see here
  2. Build a pipeline see streamz docs on how to do this.
  3. When the data comes in from the message bus have the dispatcher (see 1) send the data into the pipeline.

An implementation of this lives here which is a bit much because it handles its own data model, but is roughly there, we define a dispatcher rd and then subscribe a callable to it rd.subscribe(rr) which pushes data into the pipeline.

CJ-Wright avatar Aug 26 '19 02:08 CJ-Wright