Data streaming

High-speed parallel stream engine & local web dashboard for streaming HTTP/HTTPS downloads directly to PlayStation 5 FTP storage. Pure Python standard library, zero pip packages, macOS & Windows.

Stream your phone camera to your own PC from anywhere (4G/5G) and write it to disk in real time. Nothing stored on the phone. End-to-end encrypted, single Windows exe.

A-share historical Level-2 data: 10-level quotes, order-by-order entrusts, trade-by-trade executions, selective archive extraction and MCP-ready workflow.

End-to-end retail analytics and recommendation platform using PySpark, Kafka, PostgreSQL, Power BI, PyTorch Two-Tower, Qdrant, FastAPI, Docker and Azure.

Production-grade Kafka transport for NestJS microservices built on @platformatic/kafka: drop-in replacement for the kafkajs transport with request-reply, retries, dead-letter topics and batches.

The Diavasi Elixir client

A jev intelligence layer for event stream to classify the app traffic into human vs ai_agent vs seo_tool vs scraper vs other_automation with bad_intent probability

Real-time Ethereum whale tracker with WebSocket transaction streaming, ETH/ERC-20 decoding, and instant Telegram alerts above a configurable USD threshold. Wallet labels, counterparty analysis, smart-money PnL, exchange flows, SQLite storage, CSV/XLSX/JSON export, auto-reconnect, and cross-platform Python support.

Durable consumer groups for existing databases. Turn queries into resumable, parallel streams without changing your producers.

Streaming generative UI for React. Render HTML and schema-defined React components from LLM output.

Lumelight 3D — Moonlight-based glasses-free 3D streaming for Leia lightfield panels (Lume Pad 2, Red Magic 3D Explorer)

Low-Latency 720p 60 FPS PC Game Streaming on a Stock, Unmodded Nintendo Switch Lite

Database-Backed Consumer Groups for Searchable Event Streams

EtherDB is a high-performance, SQL-driven time-series database (TSDB) written from scratch in C++17. 840KB Bin,8MB RAM, 1.8M writes/sec, 1.5M rows/sec fetch on ARM D2000

Template for streaming IIoT sensor readings into Apache Iceberg on Amazon S3 Tables with Kinesis, Firehose, a Go transform, and Lake Formation cross-account sharing.

Ultra-fast, lightweight pure-Rust stream processing engine for IoT & edge analytics (by I-Dacs Labs)

Stream PostgreSQL changes into standard Apache Iceberg tables, built in Rust.

Telemetry as agentic short-term memory. One binary: OTLP in, Arrow blocks out, sub-15ms queries, an MCP endpoint your agent can actually reason over.

Fastest open-source data quality engine. Polars streaming + SQL pushdown. 259M rows in 1.5s.

Onchain listeners and a technical reference for the FOMO trading app on Solana and Robinhood Chain