streamz
streamz copied to clipboard
python-streamz
Real-time stream processing for python
i have this sdf ``` from streamz import Stream source = Stream.filenames('~/jupyter/streams/csv/*.csv', poll_interval=0.1) source.start() example = pd.DataFrame({'cnt': [], 'word': []}) sdf = source.map(pd.read_csv).to_dataframe(example=example) sdf ``` I just want to visualize...
In the docs, there are examples for groupby after windowing. Is there a straightforward way to reverse these operations (leading up to building a user session)?
Hey guys, Great work here, I just have a problem understanding how we translate a stream of dataframe so we can use tail() etc. I have a coroutine, that emits...
It seems that when gathering after a `unique` on a `DaskStream` the results fail to be returned to their non future state. However, this seems limited to only `unique` on...
It would be useful when explaining streamz to have a live source of data. Are there any good web APIs that we can query from somewhat rapidly without making anyone...
Hi, I have tried out a bit with the stream visualization using Random, it is a very cool feature. With some tweaks, I think I will be able to plot...
I'm wondering if we can avoid long tracebacks: ```py3 In [1]: from streamz import Stream In [2]: s = Stream() In [3]: snext = s ...: for i in range(10):...
Would it be possible to have an `.edit()` method on the nodes so that it opens a GUI which we can use to delete/add nodes and connections? I guess this...
Say I have two source streams on kafka, one updating at 1 message per second, and one updating at 5 messages per second. I am using a `combine_latest` to join...
Hi all, I'd like to congratulate the team for the fantastic project! Excellent work! Is there any plans to add MQTT as a source? If not, I might do it...
