python-streamz/streamz

View on GitHub

Real-time stream processing for python

Stars: 1.3k
Forks: 149
Open beginner issues: 0
Indexed issues: 114

Dominant language: Python
License: BSD-3-Clause
Last GitHub push: Apr 7, 2026
Latest indexed: Sep 21, 2026
Contributing guide: Contributing guide
Code of conduct: No code of conduct
Beginner labels: No beginner labels indexed
PR merge metrics: No merged PRs in 30d

Beginner friendly Everything

Open All

114 open issues indexed

pkg_resources warning Open

Difficulty 3/5 1-2 days Newbie friendliness 35/100

python-streamz/streamz#481 · 4 comments · Opened Jun 23, 2025
Combining the streamz.Stream.filenames() and streamz.Stream.from_textfile() using dask scatter? Open

Difficulty 5/5 Over a week Newbie friendliness 25/100

python-streamz/streamz#480 · 2 comments · Opened Feb 10, 2025
Compile the code into c++ Open

Difficulty 5/5 Over a week Newbie friendliness 20/100

python-streamz/streamz#479 · 1 comment · Opened Oct 28, 2024
Suggestions for improving code performance Open

Difficulty 5/5 Over a week Newbie friendliness 20/100

python-streamz/streamz#478 · 6 comments · Opened Sep 17, 2024
Is streamz not maintained anymore? What happened to cuStreamz? Open

Difficulty 4/5 3-5 days Newbie friendliness 10/100

python-streamz/streamz#476 · 17 comments · 2 reactions · Opened Apr 28, 2024
Parallel streams with buffers Open

Difficulty 4/5 3-5 days Newbie friendliness 35/100

python-streamz/streamz#475 · 3 comments · Opened Mar 28, 2024
Streamz with websocket not steaming any data Open

Difficulty 3/5 1-2 days Newbie friendliness 25/100

python-streamz/streamz#474 · 5 comments · Opened Feb 3, 2024
streamz's typing system can't work properly in vscode Open

Difficulty 4/5 3-5 days Newbie friendliness 25/100

python-streamz/streamz#473 · 2 comments · 1 reaction · Opened Nov 2, 2023
Streamz hvplot resets zoom and pan on each update Open

Difficulty 4/5 3-5 days Newbie friendliness 30/100

python-streamz/streamz#472 · 4 comments · Opened Oct 25, 2023
Add pytest fixture to clean up the IO loop Open

Difficulty 3/5 1-2 days Newbie friendliness 38/100

python-streamz/streamz#471 · 4 comments · Opened Oct 13, 2023
Hello from LorryStream and Kotori / Streamz is cool Open

Difficulty 5/5 Over a week Newbie friendliness 10/100

python-streamz/streamz#470 · 2 comments · Opened Sep 12, 2023
Quickstart lacks conda/environments/streamz_dev.yml Open

Difficulty 3/5 1-2 days Newbie friendliness 42/100

python-streamz/streamz#469 · 6 comments · Opened Sep 10, 2023
Collect does not allow awaitable sinks Open

Difficulty 3/5 1-2 days Newbie friendliness 48/100

python-streamz/streamz#468 · Opened Apr 4, 2023
Streamz not working in Jupyterlite Open

Difficulty 4/5 3-5 days Newbie friendliness 42/100

python-streamz/streamz#467 · Opened Feb 4, 2023
Time based lookback window? Open

Difficulty 5/5 Over a week Newbie friendliness 25/100

python-streamz/streamz#466 · 1 comment · Opened Jan 17, 2023
Is it possible to use event time/syntethic time rather than system time? Open

Difficulty 5/5 Over a week Newbie friendliness 30/100

python-streamz/streamz#465 · 2 comments · Opened Jan 16, 2023
visualizing streams and changing variables during runtime Open

Difficulty 5/5 Over a week Newbie friendliness 20/100

python-streamz/streamz#464 · 5 comments · Opened Dec 30, 2022
Dropping `pkg_resources` Open

Difficulty 2/5 1-3 hours Newbie friendliness 55/100

python-streamz/streamz#460 · 4 comments · 1 reaction · Opened Dec 6, 2022
How to load initial state or backfill the stream dataframe Open

Difficulty 5/5 Over a week Newbie friendliness 25/100

python-streamz/streamz#452 · 2 comments · Opened Jun 23, 2022
How to store information from PeriodicDataFrame Open

Difficulty 5/5 Over a week Newbie friendliness 20/100

python-streamz/streamz#451 · 1 comment · Opened Jun 10, 2022
Gracefully exit python script using Streams Open

Difficulty 4/5 3-5 days Newbie friendliness 25/100

python-streamz/streamz#450 · 1 comment · 1 reaction · Opened Apr 29, 2022
Streamz/Dask: gather does not wait for all results of buffer Open

Difficulty 4/5 3-5 days Newbie friendliness 35/100

python-streamz/streamz#449 · Opened Apr 12, 2022
Fail to extend a Stream with new methods Open

Difficulty 3/5 1-2 days Newbie friendliness 45/100

python-streamz/streamz#442 · 6 comments · Opened Dec 5, 2021
Increase the usage of augmented assignment statements Open

Difficulty 4/5 3-5 days Newbie friendliness 35/100

python-streamz/streamz#440 · Opened Nov 21, 2021
Integrate with River Open

Difficulty 5/5 Over a week Newbie friendliness 30/100

python-streamz/streamz#432 · Opened Sep 22, 2021
Simple example of stream with Asyncio operations Open

Difficulty 4/5 3-5 days Newbie friendliness 25/100

python-streamz/streamz#429 · 2 comments · Opened Sep 11, 2021
Does Streamz support modin/vaex/koalas? Open

Difficulty 5/5 Over a week Newbie friendliness 25/100

python-streamz/streamz#428 · 1 comment · Opened Aug 30, 2021
Using partition "breaks" program logic Open

Difficulty 4/5 3-5 days Newbie friendliness 28/100

python-streamz/streamz#427 · 2 comments · Opened Jul 14, 2021
Speed tests with a Stream? Open

Difficulty 3/5 1-2 days Newbie friendliness 25/100

python-streamz/streamz#419 · 5 comments · Opened May 24, 2021
Accumulate without emit/output Open

Difficulty 3/5 1-2 days Newbie friendliness 35/100

python-streamz/streamz#417 · Opened May 9, 2021
Real tail of stream (last n elements) Open

Difficulty 4/5 3-5 days Newbie friendliness 32/100

python-streamz/streamz#415 · 3 comments · Opened Apr 20, 2021
a logo for streamz? Open

Difficulty 5/5 Over a week Newbie friendliness 25/100

python-streamz/streamz#409 · 4 comments · Opened Mar 5, 2021
to_kafka throughput Open

Difficulty 4/5 3-5 days Newbie friendliness 35/100

python-streamz/streamz#398 · 13 comments · 1 reaction · Opened Dec 4, 2020
Custom aggregations on GroupBy dataframes Open

Difficulty 5/5 Over a week Newbie friendliness 25/100

python-streamz/streamz#388 · 3 comments · Opened Nov 16, 2020
dask-streamz based on the actor interface Open

Difficulty 5/5 Over a week Newbie friendliness 25/100

python-streamz/streamz#369 · 3 comments · Opened Oct 28, 2020
PROPOSAL: Update docs Open

Difficulty 5/5 Over a week Newbie friendliness 20/100

python-streamz/streamz#359 · 4 comments · Opened Sep 2, 2020
TTL support in Streamz Open

Difficulty 5/5 Over a week Newbie friendliness 25/100

python-streamz/streamz#356 · 1 comment · 2 reactions · Opened Aug 27, 2020
Proposal: Watermarking Open

Difficulty 5/5 Over a week Newbie friendliness 25/100

python-streamz/streamz#354 · 4 comments · 1 reaction · Opened Aug 19, 2020
Proposal: Publishing and Retrieving SDFs for SDF Checkpointing Open

Difficulty 5/5 Over a week Newbie friendliness 25/100

python-streamz/streamz#353 · 33 comments · Opened Aug 17, 2020
Streamz Benchmarking Open

Difficulty 4/5 3-5 days Newbie friendliness 38/100

python-streamz/streamz#352 · 19 comments · Opened Aug 14, 2020
Aggregating data every n elements Open

Difficulty 5/5 Over a week Newbie friendliness 25/100

python-streamz/streamz#351 · 3 comments · Opened Aug 13, 2020
Streamz + Panel Plotting Issue Open

Difficulty 3/5 1-2 days Newbie friendliness 35/100

python-streamz/streamz#344 · 2 comments · 1 reaction · Opened Jun 23, 2020
Max/Min for SDF.groupby() objects. Open

Difficulty 4/5 3-5 days Newbie friendliness 30/100

python-streamz/streamz#342 · 2 comments · Opened Jun 13, 2020
Ray.io Open

Difficulty 5/5 Over a week Newbie friendliness 25/100

python-streamz/streamz#334 · 7 comments · Opened May 14, 2020
Dask example from docs does not work Open

Difficulty 4/5 3-5 days Newbie friendliness 45/100

python-streamz/streamz#333 · 5 comments · Opened May 4, 2020
Don't maintain state for some objects Open

Difficulty 5/5 Over a week Newbie friendliness 35/100

python-streamz/streamz#329 · Opened Apr 21, 2020
Are GeoPandas GeoDataFrames supported? Open

Difficulty 5/5 Over a week Newbie friendliness 25/100

python-streamz/streamz#325 · 3 comments · Opened Apr 3, 2020
0.5.3 is not backwards compatible Open

Difficulty 4/5 3-5 days Newbie friendliness 35/100

python-streamz/streamz#323 · 5 comments · Opened Apr 2, 2020
AnyIO implementation of asynchronous streams Open

Difficulty 5/5 Over a week Newbie friendliness 25/100

python-streamz/streamz#320 · 14 comments · 1 reaction · Opened Mar 30, 2020
Write to Kafka from Dask Stream Open

Difficulty 5/5 Over a week Newbie friendliness 25/100

python-streamz/streamz#315 · 2 reactions · Opened Mar 19, 2020

python-streamz/streamz

Get new issues in your inbox