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

How can I put an tensorflow model as args into a map function? Open

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

python-streamz/streamz#314 · 1 comment · Opened Mar 18, 2020
Multi-kafka for high availability Open

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

python-streamz/streamz#308 · 5 comments · Opened Mar 10, 2020
Jupyterlab cell output issue Open

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

python-streamz/streamz#307 · 1 comment · Opened Mar 2, 2020
OpenCV Video Capture Source Open

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

python-streamz/streamz#291 · 13 comments · Opened Dec 9, 2019
Upgrade Travis CI python version Open

Difficulty 1/5 Under an hour Newbie friendliness 55/100

python-streamz/streamz#289 · 1 reaction · Opened Dec 4, 2019
'cannot reuse already awaited coroutine' with timed_window on Python 3.7.5 Open

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

python-streamz/streamz#284 · Opened Nov 29, 2019
Install docs Open

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

python-streamz/streamz#280 · 1 comment · Opened Nov 14, 2019
add BLE "iBeacon" source with Bluez Open

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

python-streamz/streamz#275 · 1 comment · Opened Sep 18, 2019
add "at_time" source Open

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

python-streamz/streamz#274 · 7 comments · Opened Sep 18, 2019
Any support for RabbitMQ ? Open

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

python-streamz/streamz#269 · 4 comments · Opened Aug 26, 2019
Unable to filter using Dataframe RuntimeError: There is no current event loop in thread Open

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

python-streamz/streamz#265 · Opened Aug 14, 2019
map node inspection Open

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

python-streamz/streamz#264 · 3 comments · Opened Jul 29, 2019
Dask leaks memory with Batched Kafka and cudf Open

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

python-streamz/streamz#258 · 5 comments · Opened Jun 12, 2019
Script does not finish with dask distributed Open

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

python-streamz/streamz#257 · 9 comments · Opened Jun 11, 2019
Memory leak with _global_sinks Open

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

python-streamz/streamz#252 · 14 comments · Opened May 22, 2019
ENH: add interval to window/rolling Open

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

python-streamz/streamz#246 · 6 comments · Opened May 2, 2019
Issues scaling kafka consumers with Dask Open

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

python-streamz/streamz#240 · 20 comments · Opened Apr 9, 2019
Reuse Kafka consumer for polling next batch Open

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

python-streamz/streamz#225 · 4 comments · Opened Feb 28, 2019
Profiling streamz pipeline with from_kafka_batched Open

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

python-streamz/streamz#221 · 2 comments · Opened Jan 25, 2019
corr and ewm Open

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

python-streamz/streamz#220 · 3 comments · Opened Jan 21, 2019
Flatten doesn't work with DaskStream Open

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

python-streamz/streamz#213 · 5 comments · Opened Nov 13, 2018
Silent fail / exit with streamz >= 0.4.0 when pipeline is being run in a daemon process Open

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

python-streamz/streamz#212 · 2 comments · Opened Nov 2, 2018
Separate parallel backend from frontend Open

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

python-streamz/streamz#198 · 2 comments · Opened Aug 12, 2018
Filter DaskStream Open

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

python-streamz/streamz#195 · 7 comments · Opened Aug 8, 2018
extend networkx Open

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

python-streamz/streamz#188 · 5 comments · 1 reaction · Opened Jul 11, 2018
how can we just convert streamz.dataframe into a normal dataframe? Open

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

python-streamz/streamz#183 · 2 comments · Opened Jun 5, 2018
Windowing after groupby? Open

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

python-streamz/streamz#179 · 1 comment · Opened May 15, 2018
[Q] stream asyncio dataframes to_dataframe usage Open

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

python-streamz/streamz#177 · 1 reaction · Opened May 10, 2018
unique on dask fails to gather results properly Open

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

python-streamz/streamz#169 · 3 comments · Opened Apr 24, 2018
ENH: DaskStream from set of futures Open

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

python-streamz/streamz#163 · 4 comments · Opened Apr 5, 2018
stream visualization with x axis Open

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

python-streamz/streamz#162 · 2 comments · Opened Apr 4, 2018
long tracebacks Open

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

python-streamz/streamz#157 · 1 comment · Opened Mar 20, 2018
Non-blocking File I/O Open

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

python-streamz/streamz#156 · 7 comments · Opened Mar 14, 2018
How to keep some sort of ordering between joined streams? Open

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

python-streamz/streamz#155 · 3 comments · Opened Mar 12, 2018
Create and maintain changelog Open

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

python-streamz/streamz#149 · 1 comment · Opened Feb 23, 2018
Include tests in conda-forge package Open

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

python-streamz/streamz#144 · 1 comment · Opened Jan 17, 2018
put `emit_on` information into graph visualization Open

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

python-streamz/streamz#139 · Opened Jan 10, 2018
Problem with `timed_window` with asyncio Open

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

python-streamz/streamz#131 · 3 comments · 1 reaction · Opened Nov 30, 2017
Holoviews plotting issues Open

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

python-streamz/streamz#128 · Opened Nov 24, 2017
Streaming dataframe visualization Open

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

python-streamz/streamz#126 · 12 comments · Opened Nov 21, 2017
MQTT Support - Streaming sensor data for IoT use case Open

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

python-streamz/streamz#125 · 4 comments · 1 reaction · Opened Nov 17, 2017
Speed testing Open

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

python-streamz/streamz#123 · 1 reaction · Opened Nov 8, 2017
Live OHLC V resampling Open

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

python-streamz/streamz#119 · 7 comments · Opened Nov 2, 2017
Gate node, super node or docs Open

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

python-streamz/streamz#118 · 3 comments · Opened Oct 31, 2017
ENH: plot execution order on graph Open

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

python-streamz/streamz#115 · Opened Oct 27, 2017
Plumbing metadata Open

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

python-streamz/streamz#110 · 8 comments · Opened Oct 18, 2017
Example: Read growing log file, create a dataframe or append to existing data frame? Open

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

python-streamz/streamz#103 · 15 comments · Opened Oct 17, 2017
editing pipeline Open

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

python-streamz/streamz#89 · 5 comments · Opened Oct 10, 2017
Should streamz handle exceptions? Open

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

python-streamz/streamz#86 · 7 comments · Opened Oct 10, 2017
Live source for experimentation and demonstration Open

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

python-streamz/streamz#78 · 8 comments · Opened Oct 4, 2017

python-streamz/streamz

Get new issues in your inbox