An example of using Redis Streams, RedisGears, RedisAI and RedisTimeSeries for Realtime Video Analytics (i.e. counting people)
A simple Redis Streams backed Chat app using Websockets, Asyncio and FastAPI/Starlette.
Distributed event processing for Python based on Redis Streams
An example of using Redis Streams, RedisGears and RedisAI for Realtime Video Analytics (i.e. filtering cats)
A task queue library for Python and Redis
Event-driven microservices architecture with Django, Redis Streams, and PostgreSQL. Demonstrates real-time updates, event deduplication, and scalable distributed systems.
Python Stream Processing With Redis Streams
This is a simple microservices app built with FastAPI and React, using RedisJSON for the database and Redis Streams for event dispatch. It provides a user-friendly interface and easy data storage and event dispatch for microservices apps.
Stream fleet, customs, rail, and carrier telemetry/metadata as unified low latency event spans.
A high-performance, async market data gateway for Crypto (Binance) and VN Stocks (DNSE/vnstock). Features historical Parquet warmups, live Redis Pub/Sub streaming, and auto-failover.
A real-time, zero-trust governance layer that sits between AI agents and the outside world.
MCP-native AI agent OS — Redis bus, squad service, multi-model engine. Connect any agent with one URL.
Auditable multi-agent AI paper-trading system: four LLM agents debate market headlines, pass risk gates, and publish replayable decision traces. LangGraph · FastAPI · React · Supabase · Redis Streams · Alpaca.
Distributed compliance and eligibility engine for multi-market e-commerce. 4 microservices, 25 rules, 12 markets.
Self-hosted AI security camera platform — multi-camera YOLOv8 detection, InsightFace recognition, and a Qwen 3 14B chat assistant with 19 tools. Docker Compose, zero cloud.
High-throughput event ingestion and analytics pipeline built with FastAPI, Redis Streams, and PostgreSQL partitioned storage.
Asynchronous document processing service with configurable pipeline, pluggable providers, and event-driven architecture using Redis Streams and background workers.
Distributed security audit and observability system for OmniBioAI — Redis Streams-based real-time event pipeline capturing authentication events, policy decisions, data access, and system actions across all platform services. Provides zero-trust traceability, tamper-evident audit logs, and scalable event replay for compliance and forensics.
Industrial AI predictive maintenance — physics-based simulation, explainable ML (SHAP, conformal RUL), ISA-18.2 alarm management, EU AI Act-compliant decision engine. Live demo: pdm.muratsuer.eu
MinIO events to Redis Streams data pipeline implemented in Python 3 🐍
Add a description, image, and links to the redis-streams topic page so that developers can more easily learn about it.
To associate your repository with the redis-streams topic, visit your repo's landing page and select "manage topics."