streamz
streamz copied to clipboard
python-streamz
Real-time stream processing for python
Is it possible to create a dataframe from a growing log file, or is pygtail a better approach?
We are developing a tool for streaming N-D arrays from low level languages (Fortran/C) to Python. We are using Redis and are in the process of designing an Xarray backend...
We should eventually make sure this gets into the documentation (in reaction to #72) Something like: ```python s = Stream() s2 = s.map(lambda x : x + 1) s2.map(print) s.emit(1)...
One could imagine using accumulate to sum things together (or do something else) until some threshold is met and then starting the average all over again (resetting the result to...
Currently `zip_latest` only buffers the first stream, we may want to buffer multiple streams.
Is it possible to color each node in graphvis? If so we may want to come up with a color scheme such that every node type has a dedicated color...
The dask extensions have given us the ability to parallelize on the "inside a node" level. However, some nodes can be run completely independently from one another. What is the...
RX has some nice tutorials, with great graphs showing how streams get combined, eg [combine latest](http://reactivex.io/documentation/operators/combinelatest.html). It would be nice if we could have these too, especially as we have...
Here is my attempt at an example: ```python from streams import Streams from operator import mul s1 = Stream() s2 = Stream() op = s1.product(s2, mul) L = op.sink_to_list() a...