streamz
streamz copied to clipboard
python-streamz
Real-time stream processing for python
Is it possible to start a sdf or stream with an initial state or backfill the sdf with values from a database or cache?
i am new to coding, so apologies for asking this. I am looking to store the data that comes in through PeriodicDataFrame. My project is to intake Barometric Pressure every...
I have a use case associated with pulling data from a Kafka topic. I need the streamz operator exit gracefully and exit the python script once it hits an exception....
Hi Streamz team. I was following the docs to use streamz with dask and facing the issue that dask returns before all the results are calculated, when used with buffer....
To my knowledge there is currently no way to show (or plot) the last n elements of a Streamz DataFrame. I think this is a very useful function for debugging,...
Simply copying the script code to a notebook. Could use some cleaning and prose. For some reason, we are getting lookback on the cluster centres, whereas we should only be...
This PR provides a constructor on the `Stream` which can be overridden for sub-classing the nodes. This is to create or override methods without altering the original Stream class. It...
Inheritance on a Stream seems to be broken. The following example fails with `'map' object has no attribute 'draw'` : ```python import streamz class MyStream(streamz.Stream) : def draw(self) : print('called...
Hello, let's imagine you are receiving trades from an exchange (buy/sell, price, volume). Streamz should provide a way to live resample this kind of data. price could be resampled using...
:eyes: Some source code analysis tools can help to find opportunities for improving software components. :thought_balloon: I propose to [increase the usage of augmented assignment statements](https://docs.python.org/3/reference/simple_stmts.html#augmented-assignment-statements "Augmented assignment statements") accordingly....
