Examples - Datris

The examples/ directory contains standalone applications that integrate with and extend the Datris platform. From a full-blown AI agent to simple utility scripts — each demonstrates a different way to use Datris.

Agent

Example	Description
Market Macro Agent	MacroAgent — a real-time financial data pipeline agent. Connects to Datris via MCP, fetches live market data (FRED, yfinance, CoinGecko, SEC EDGAR), creates pipelines, ingests data, and answers market questions — all visible in a browser UI. Full agentic loop with background refresh.

Data Processing

Example	Description
Preprocessor	Flask REST API for preprocessing data before pipeline ingestion. Synchronous and asynchronous modes.

Data Ingestion

Example	Description
Kafka CSV Loader	Kafka producer that publishes CSV data to topics for streaming ingestion.
Topic Subscriber	ActiveMQ consumer that listens for pipeline completion notifications to trigger downstream workflows.

Search & RAG

Example	Description
Chat Vector Store	Unified RAG chat app supporting all 5 vector stores (Qdrant, Weaviate, Milvus, Chroma, pgvector).

Testing

Example	Description
MCP Server Test	Integration test exercising MCP tools end-to-end: create pipeline, upload, query, cleanup.