Materialize is a streaming database for real-time analytics. This is a collection of Materialize demos and tutorials.

📡 Real-time data pipeline with Kafka, Flink, Iceberg, Trino, MinIO, and Superset. Ideal for learning data systems.

专业的金融市场数据 MCP 服务器 - 支持A股/美股/加密货币，原生 MCP 协议，AI Agent 友好

Python wrapper for the Tradier brokerage API

Rockset community content

An advanced tool designed for creating automated news bulletins. It generates dynamic news scripts using OpenAI, and provides voice narration using either OpenAI or ElevenLabs text-to-speech services. The system supports seamless integration with AzuraCast and S3 for content storage and distribution, making it a versatile solution for broadcasters.

Manipulate satoshi-related prices in Python 3, simple and sweet 💵 ₿🍬

Insurance AI Assistant A smart system combining PostgreSQL, Milvus, and specialized AI agents (Life/Home/Auto) to answer insurance queries accurately. Features real-time sync, semantic search via OpenAI embeddings, and a Streamlit UI. Perfect for insurance tech demos or customer service augmentation.

This repository houses a full-stack application which is used to create a real time stock price dashboard in Python, with the use of the streamlit and yfinance libraries.

🤖 Simplify multi-turn conversations with CodexAgent, a DSPy module for OpenAI Codex, offering stateful threads and rich, typed outputs.

Hands-on demo for querying Kafka streams using SQL with Trino and data integration with PostgreSQL.

Scrape-AI is a Python library for intelligent web scraping using LLMs like, OpenAI, Anthropicand Selenium. It dynamically fetches data based on user queries, enabling agent-like scraping with configurable models, modular design, and support for real-time data extraction from dynamic websites.

Implementation for our paper “NewTerm: Benchmarking Real-Time New Terms for Large Language Models with Annual Updates,” accepted to NeurIPS 2024 D&B. 🎉

A Python library for algorithmic trading and technical analysis. Integrates 7+ data providers, 50+ indicators, with smart caching to minimize API costs. Built for performance and reliability.

Comprehensive multithreading-communication app using QThread, socket, pyqtSignal, ftplib, serial, cv2, OpenGL, pyqtgraph, PyGame, etc. Including topics such as real-time data transfer, ESP32-CAM Video Streaming, telemetry transfer over UDP, file transfer over FTP, data transfer from serial port.

Full-stack app that predicts player performance across MLB, NBA, and NFL using position-specific Random Forests.

Web dashboard made with streamlit to plot data and control 2 APIs made with fastapi. API to control UM34C via bluetooth and an API to store the data from UM34C in a database

EHR pipeline that simulates MIMIC-IV patient data streams, performs advanced feature engineering and clinical severity scoring using machine learning (Random Forest Classifier), and prepares structured outputs for scalable downstream analytics

A novel real-time event prediction method for heterogeneous multivariate temporal data (time point values, instantaneous events, or time intervals) that leverages multiple instances of multiple temporal patterns

This solution accelerator provides the architecture and working solution for real-time intelligence for operations. Key features include real-time dashboard, anomaly detection, and fabric data agent.