streamz
streamz copied to clipboard
python-streamz
Real-time stream processing for python
Work in progress: A (naive?) stab at generic exception handling within streamz. This PR attaches an exception handler to each Stream object that acts as an optional start of a...
I know we talked about updating the documentation so that it is more current and reads better (not that it doesn't read well now, but I feel certain API/aspects of...
I am trying to compare the speed of operation when a Stream is introduced into the code. These are both scripts that need to be run. A 'plain' Python example:...
Hi, I've been following the docs and reading through the tests, and I cannot get streamz working with Asyncio :/ Here's a very minimal example of a stream comprising of...
I am struggling to use `partition` in a pipeline because it "breaks" the logic of my program; presumably because it introduces asynchronous processing. As a simplified example, I have something...
https://riverml.xyz/latest/ provides online, per-event machine learning. Whilst we have tried to approach them to accept streamz as a known type of input, it makes sense to just do it here....
[Copy-pasting part of the description of #340] To checkpoint the state of an SDF, we need to do 3 things: 1. When a job starts, retrieve (either from Dask datasets/S3/disk)...
Does Streamz support modin or vaex? Besides pandas/dask, I'm thinking of trying a few more solutions.
Anyone with talent to create such a thing? Something like  springs to mind; or perhaps something made from our own example graphviz output.
According to the documentation of `accumulate` ([Accumulating State](https://streamz.readthedocs.io/en/latest/core.html#accumulating-state)), it is possible to not have `accumulate` "output" anything: > One piece of data comes in, either one or zero pieces go...