real-time-streaming-data

Here are 6 public repositories matching this topic...

acourreg / patternalarm

Real-time fraud detection pipeline. Kafka ingests 10K+ events/min, Flink aggregates, Spark ML scores at 97.5% accuracy. ~$300/month gets you 3,700 predictions/min, <3s latency, auto-scaling to zero. Airflow + Terraform IaC. 79x throughput improvement via batch optimization.

python aws scala terraform data-engineering apache-flink apache-kafka fraud-detection spark-ml real-time-streaming-data

Updated Jan 19, 2026
Python

thekripaverse / Real-Time-E-Commerce-Data-Streaming-Pipeline-using-Kafka-and-Snowflake

Star

A real-time data streaming system that captures live e-commerce order events using Apache Kafka and ingests them into Snowflake for near real-time analytics.

docker kafka snowflake data-engineering event-driven real-time-streaming-data

Updated Jan 22, 2026
Python

krist-18 / twitch-streams-by-category

Star

Twitch category live stream data extractor

twitch-scraping esports-analytics video-metadata-scraper live-stream-analytics gaming-data-extraction streamer-insights viewer-statistics twitch-category-crawler content-discovery-tools real-time-streaming-data

Updated Nov 11, 2025
Python

patel-priyal-m / Forex-rate--monitor-and-alert-system

Star

A production-ready real-time FX rate monitoring system demonstrating enterprise architecture with Kafka, multiprocessing, and real-time dashboards

distributed-systems multiprocessing production-monitoring real-time-streaming-data resrful-api

Updated Feb 6, 2026
Python

sharma93manvi / methanex-anomaly-detection

Star

Early Detection of Process Excursions from Sensor Data - AI-powered anomaly detection with Upload & Analysis, Mock Stream, and Gemini Chat Agent

machine-learning-algorithms google-cloud sensor-data lstm-neural-networks ai-agents isolation-forest gemini-api early-detection autoencoder-neural-network gemini-chatbot statitstical-analysis real-time-streaming-data hackathon2026

Updated Feb 22, 2026
Python

Mohith-akash / Vortex-The-Revenue-Recovery-Engine

Star

Real-Time Lakehouse on Azure & Databricks. Ingests clickstream events via Event Hubs & Delta Live Tables (DLT) with <500ms latency to trigger Agentic AI recovery workflows.

python sql stream-processing data-engineering databricks azure-event-hubs streamlit analytics-engineering lakehouse delta-live-tables dbt-core generative-ai medallion-architecture cerebras llama-3 agentic-ai voyage-ai real-time-streaming-data

Updated Jul 12, 2026
Python

Improve this page

Add a description, image, and links to the real-time-streaming-data topic page so that developers can more easily learn about it.

Curate this topic

Add this topic to your repo

To associate your repository with the real-time-streaming-data topic, visit your repo's landing page and select "manage topics."

Learn more