Streamz
Real-time stream processing for python
Install / Use
/learn @python-streamz/StreamzREADME
Streamz
|Build Status| |Doc Status| |Version Status| |RAPIDS custreamz gpuCI|
Streamz helps you build pipelines to manage continuous streams of data. It is simple to use in simple cases, but also supports complex pipelines that involve branching, joining, flow control, feedback, back pressure, and so on.
Optionally, Streamz can also work with both Pandas <https://pandas.pydata.org/pandas-docs/stable/reference/api/pandas.DataFrame.html>_ and cuDF <https://docs.rapids.ai/api/cudf/stable/>_ dataframes, to provide sensible streaming operations on continuous tabular data.
To learn more about how to use Streamz see documentation at streamz.readthedocs.org <https://streamz.readthedocs.org>_.
LICENSE
BSD-3 Clause
.. |Build Status| image:: https://github.com/python-streamz/streamz/workflows/CI/badge.svg :target: https://github.com/python-streamz/streamz/actions .. |Doc Status| image:: http://readthedocs.org/projects/streamz/badge/?version=latest :target: http://streamz.readthedocs.org/en/latest/ :alt: Documentation Status .. |Version Status| image:: https://img.shields.io/pypi/v/streamz.svg :target: https://pypi.python.org/pypi/streamz/ .. |RAPIDS custreamz gpuCI| image:: https://img.shields.io/badge/gpuCI-custreamz-green :target: https://github.com/jdye64/cudf/blob/kratos/python/custreamz/custreamz/kafka.py
Related Skills
node-connect
347.6kDiagnose OpenClaw node connection and pairing failures for Android, iOS, and macOS companion apps
claude-opus-4-5-migration
108.4kMigrate prompts and code from Claude Sonnet 4.0, Sonnet 4.5, or Opus 4.1 to Opus 4.5
frontend-design
108.4kCreate distinctive, production-grade frontend interfaces with high design quality. Use this skill when the user asks to build web components, pages, or applications. Generates creative, polished code that avoids generic AI aesthetics.
model-usage
347.6kUse CodexBar CLI local cost usage to summarize per-model usage for Codex or Claude, including the current (most recent) model or a full model breakdown. Trigger when asked for model-level usage/cost data from codexbar, or when you need a scriptable per-model summary from codexbar cost JSON.
