streamz
streamz copied to clipboard
python-streamz
Real-time stream processing for python
Hi, thanks for the great project! What I'm trying to achieve is to create a custom builder interface/wrapper around streamz to have predefined building blocks of preconfigured streams which can...
ipywidgets version 8.0 no longer uses `_ipython_display_`, giving the following error in a notebook when trying to display a streamz dataframe.:  This PR adds a check for `__repr_mimebundle__` and...
I am trying to figure out a right way of streaming data using streamz with websocket. My streaming data is loaded using websocket but not streaming anything. ```python import config...
### summary streamz's typing system can't work properly in vscode, severely reduceing user experience. ### vscode version Version: 1.83.1 (system setup) Commit: f1b07bd25dfad64b0167beb15359ae573aecd2cc Date: 2023-10-10T23:48:05.904Z Electron: 25.8.4 ElectronBuildId: 24154031 Chromium:...
I'm plotting a large amount of streaming data using streamz and I'm very happy with the performance. Here is how I create the stream, data frame, and the line: ```...
I recently came across this error in my unit tests: ``` RuntimeError: This event loop is already running ``` The error doesn't come from streamz, it's from jupyter_core, in [this...
Having cloned this repo (master at b4f0450586), I failed to run the [Quickstart](https://streamz.readthedocs.io/en/latest/#quickstart); viz., running ```shell cd ~/src/streamz sh docker/build.sh ``` I get > EnvironmentFileNotFound: '/streamz/conda/environments/streamz_dev.yml' file not found. Looking...
Dear Martin, originally responding to GH-469, in order to chime in on saying »Streamz is cool«, and tell you about where we are using it, I thought it would not...
The `collect` class does not allow for awaitable sinks. Small example: ```python async def sink_to_something(x): print(x) return await asyncio.sleep(1) source = streamz.Source() collector = source.collect() collector.sink(sink_to_something) for i in range(10):...
