meridian-oss 1.2.5

Heroku for ML Features

Meridian

The Context Store for LLMs & ML Features

Define RAG pipelines and ML features in Python. Get production retrieval, vector search, and training data for free.

Stop fighting the infrastructure tax. Meridian takes you from "Notebook Prototype" to "Production RAG" in 30 seconds.

📚 Documentation | 🤖 Context Store | 🛠️ Testing Guide

---

🚀 Why Meridian?

Most feature stores are built for the 1% of companies (Uber, DoorDash) with platform teams. They require Kubernetes, Spark, and complex microservices.

Meridian is built for the rest of us.

Feature	The "Old Way"	The Meridian Way
Config	500 lines of YAML	Python Decorators (@feature)
Infra	Kubernetes + Spark	Runs on your Laptop (DuckDB)
Serving	Complex API Gateway	meridian serve file.py
RAG Context	LangChain Spaghetti	Declarative @context
Philosophy	"Google Scale"	"Get it Shipped"

---

⚡ The 30-Second Quickstart

1. Install

pip install "meridian-oss[ui]"

2. Define Features & Context (features.py)

from meridian.core import FeatureStore, entity, feature
from meridian.context import context, ContextItem
from meridian.retrieval import retriever
import random

store = FeatureStore()

@entity(store)
class User:
    user_id: str

# 1. THE FEATURE STORE (Structured Data)
@feature(entity=User, refresh="daily", materialize=True)
def user_tier(user_id: str) -> str:
    # Imagine a DB lookup here; we'll simulate it for speed.
    return "premium" if hash(user_id) % 2 == 0 else "free"

# 2. THE CONTEXT STORE (Unstructured Data)
@retriever(store)
async def find_docs(query: str):
    # In production, this uses pgvector.
    # Here we simulate a semantic search result.
    return [{"content": "Meridian bridges the gap between ML features and RAG.", "score": 0.9}]

# 3. THE UNIFICATION (Context Assembly)
@context(store)
async def build_prompt(user_id: str, query: str):
    # Fetch feature and docs in parallel
    tier = await store.get_feature("user_tier", user_id)
    docs = await find_docs(query)

    return [
        ContextItem(f"User is {tier}. Adjust tone accordingly.", priority=0),
        ContextItem(str(docs), priority=1)
    ]

3. Use in Your App

import asyncio
from features import build_prompt

async def main():
    ctx = await build_prompt(user_id="u1", query="How does Meridian help?")
    print(ctx.items)
    # Output: [ContextItem(content='User is free...', ...), ContextItem(content='[{"content":...}]', ...)]

if __name__ == "__main__":
    asyncio.run(main())

4. Serve (Optional) Expose features via HTTP for non-Python apps:

meridian serve features.py
# 🚀 Server running on http://localhost:8000

---

🛠️ Key Capabilities

Meridian bridges the gap between AI Engineers building RAG agents and ML Engineers training models.

🤖 For AI Engineers (The Context Store)

• Vector Search & RAG: Built-in pgvector support. Index documents and retrieve them semantically with @retriever.
• Token Budgets: Automatically assemble prompt contexts (@context) that fit within your LLM's context window, prioritizing high-value information.
• Semantic Cache: Cache expensive LLM computations or retrieval results.
• 📖 Read the Context Store Guide

📊 For ML Engineers (The Feature Store)

• Point-in-Time Correctness: Zero data leakage. Uses ASOF JOIN (DuckDB) and LATERAL JOIN (Postgres) to fetch feature values exactly as they existed at inference time.
• Hybrid Logic: Mix Python (for complex Pandas/Numpy transformations) and SQL (for heavy database aggregations) in the same pipeline.
• Event-Driven: Trigger feature updates instantly from Redis Streams (trigger="transaction_event").

---

🏗️ Architecture

Meridian scales with you from Laptop to Production.

graph TD
    subgraph Dev [Tier 1: Local Development]
        A[Laptop] -->|Uses| B(DuckDB)
        A -->|Uses| C(In-Memory Dict)
        style Dev fill:#e1f5fe,stroke:#01579b
    end

    subgraph Prod [Tier 2: Production]
        D[API Pods] -->|Async| E[(Postgres + pgvector)]
        D -->|Async| F[(Redis)]
        style Prod fill:#fff3e0,stroke:#ff6f00
    end

    Switch{MERIDIAN_ENV} -->|development| Dev
    Switch -->|production| Prod

---

🏭 Production Configuration

Deploy to production by simply setting environment variables. No code changes required.

# Security
MERIDIAN_API_KEY=change_me_to_something_secure

# Data Stores
MERIDIAN_REDIS_URL=redis://redis-host:6379
MERIDIAN_POSTGRES_URL=postgresql+asyncpg://user:pass@db-host:5432/meridian  # pragma: allowlist secret

# LLM Providers (for RAG)
OPENAI_API_KEY=sk-...

---

🗺️ Roadmap

• ✅ Phase 1: Core API, DuckDB/Postgres support, Redis caching, FastAPI serving, PIT Correctness, Async I/O.
• ✅ Phase 2 (v1.2.0): Context Store, RAG infrastructure, pgvector, Event-Driven features, Time Travel.
• ✅ Phase 2.x (v1.2.5): Release Polish, CLI improvements, Timezone robustness.
• 🚧 Phase 3: Drift detection, RBAC, and multi-region support.

---

🤝 Contributing

We love contributions! This is a community-driven project. Please read our CONTRIBUTING.md to get started.

---

Meridian © 2025

Apache 2.0 License