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. |