Python Stream Processing
-
Updated
Nov 23, 2023 - Python
Python Stream Processing
A Python implementation of Apache Kafka Streams
Stream processing using kafka-python to track people (user input images of target) in the wild over multiple video streams.
Data Engineering examples covering Airflow and Mage for workflows; dbt for BigQuery, Redshift, ClickHouse; Spark and Kafka for Batch/Streaming Processing
Explore Apache Kafka data pipelines in Kubernetes.
Streaming Synthetic Sales Data Generator: Streaming sales data generator for Apache Kafka, written in Python
Benchmarks for data processing systems: Pathway, Spark, Flink, Kafka Streams
A real-time event pipeline around Kafka Ecosystem for Chicago Transit Authority.
Video processing (webcam) in real time using Kafka and Spark.
A end-to-end real-time stock market data pipeline with Python, AWS EC2, Apache Kafka, and Cassandra Data is processed on AWS EC2 with Apache Kafka and stored in a local Cassandra database.
Implementation of an ETL process for real-time sentiment analysis of tweets with Docker, Apache Kafka, Spark Streaming, MongoDB and Delta Lake
Deploy Kafka pipelines to Kubernetes
An naive anomaly detection and data visualization tool for F1 on board telemetry data.
Realtime IoT data streaming from Smartphone sensors
A simple implementation of Kafka message streaming using Python
A Python starter pack for building streaming applications with Memgraph.
Live sentiment analysis of tweets using Kafka
A proof of concept about collecting real-time clickstream data using Javascript, Divolte Collector, Apache Kafka, Kafka Streams, Apache Druid and Apache Superset.
A real time stock prices tracker using Kafka
Add a description, image, and links to the kafka-streams topic page so that developers can more easily learn about it.
To associate your repository with the kafka-streams topic, visit your repo's landing page and select "manage topics."