streamz
streamz copied to clipboard
python-streamz
Real-time stream processing for python
Using streamz with an event loop such as [`trio`](https://trio.readthedocs.io/en/stable/) is currently not possible since Tornado only supports AsyncIO if it is available. If we had an implementation that uses [`AnyIO`](https://anyio.readthedocs.io/),...
It seems like the exiting PR for this needs improvements. I'm creating this issue to invite discussion on now to properly solve this problem. I would like to use the...
def map(data, model): model.fit(data) I want to put an tensorflow model into map function as args, However, the model has changed compared to before. So I am unable to train...
We are setting up Kafka in multiple data centers to achieve high availability. I expected that Streamz could do a union between both of these clusters. Everything works as expected,...
From the initial blog post: >Annotate elements: we want to pass through event time, processing time, and presumably other metadata It might be good to have this discussion in the...
I just discovered steamz and think it looks great. However, when I try to run some of the sample code in a Jupyterlab notebook, I experience some strange behavior where...
The streamz.dataframe module could use a good `plot` method. This has two requirements: 1. Relatively automatic selection of plot styles 2. Support for updating results, either a full update of...
Would be nice to have more Pandas rolling window functions in streamz. I implemented rolling correlation and exponential weighted window. The EWM uses a cut-off threshold for finite window sizes....
The documentation states that streamz requires python 3.7 > however the Travis CI is configured to use python 3.6 seems like we should update that to be 3.7
What do we do when a stream receives bad data that causes an exception to be raised. For ex: ```python def foo(x): if x is None: raise Exception else: return...
