Spaces:
Running
Running
File size: 6,598 Bytes
392346c | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 | # CustomerCore System Architecture
This document provides a comprehensive technical overview of the CustomerCore platform's architecture, including its data flows, multi-agent orchestrator, and service topology.
---
## Data Flow Diagram
```mermaid
flowchart TD
subgraph Ingestion ["1. Event Ingestion"]
API[FastAPI Gateway]
GH[GitHub Issues API]
SE[Synthetic Generators]
RP[Redpanda Broker]
API -->|Publish| RP
GH -->|Webhooks| RP
SE -->|Simulate Events| RP
end
subgraph Lakehouse ["2. Streaming Lakehouse"]
SP[PySpark Structured Streaming]
R2[(Cloudflare R2 Object Storage)]
Duck[DuckDB / local dbt]
RP -->|Bronze Stream| SP
SP -->|PII Masking & Silver| R2
R2 -->|dbt transformation| Duck
end
subgraph Modeling ["3. Feature & Model Registry"]
FS[Feast Feature Store]
ML[MLflow Experiment Registry]
Models[8 Trained ML Models]
Duck -->|Gold Marts| FS
Duck -->|Train Set| ML
ML -->|Register| Models
end
subgraph Routing ["4. AI & Agent Triage Flow"]
LC[LiteLLM Routing Gateway]
SC[Semantic Cache L1/L2/L3]
LG[LangGraph Supervisor Graph]
Supa[(Supabase pgvector / db)]
API -->|Triage Request| LG
LG -->|Validate Route| LC
LC -->|Query Cache| SC
LG -->|Store Memories| Supa
end
subgraph Observability ["5. Platform Observability"]
PROM[Prometheus Metrics]
OTEL[OTel Collector]
GRAF[Grafana Cloud Dashboards]
LF[Langfuse Cloud Traces]
API -->|Export Metrics| PROM
PROM --> OTEL --> GRAF
LG -->|Traces & LLM Costs| LF
end
style RP fill:#FFDDDD,stroke:#CC0000,stroke-width:2px
style R2 fill:#FFE8D6,stroke:#D4A373,stroke-width:2px
style LG fill:#E8F0FE,stroke:#1A73E8,stroke-width:2px
style Supa fill:#D1FAE5,stroke:#059669,stroke-width:2px
style LF fill:#F3E8FF,stroke:#7C3AED,stroke-width:2px
```
---
## The Nine Core Services
CustomerCore consists of nine services divided into logical layers:
### 1. Stream Ingestion
- **Technology:** Redpanda (Kafka-compatible event broker)
- **Role:** Direct ingestion points for four parallel topic streams: `tickets`, `product`, `billing`, and `incidents`. Custom python helper classes verify broker sockets before publishing.
### 2. Stream Processing
- **Technology:** PySpark Structured Streaming
- **Role:** Sub-minute micro-batch engine processing Bronze-to-Silver data. Resolves PII redaction (email, SSN, phone) using Python UDFs and guarantees strong schema enforcement before flushing to Iceberg format.
### 3. dbt Transform Layer
- **Technology:** `dbt-core` with `dbt-duckdb`
- **Role:** Compiles silver tables into 7 separate Gold business marts (customer health metrics, incident durations, billing tiers, etc.) to drive analytics and features.
### 4. Feature Store
- **Technology:** Feast (Feature Store)
- **Role:** Offline feature store manages historical training datasets; online store (Upstash Redis) provides sub-millisecond lookup latency during real-time inference.
### 5. ML Experiment Registry
- **Technology:** MLflow hosted on DagsHub
- **Role:** Trains, registers, and tracks 8 separate models including ticket classifiers (XGBoost), churn risk engines (LightGBM), volume forecasters (Prophet), and anomaly detectors (Isolation Forest).
### 6. Vector & RAG Service
- **Technology:** ChromaDB (Dense + BM25 Hybrid Retriever)
- **Role:** Holds indexed documentation and product knowledge. Realizes hybrid search with Reciprocal Rank Fusion (RRF) and reranks retrieved candidate chunks using a cross-encoder model.
### 7. Inference API Gateway
- **Technology:** FastAPI & Uvicorn
- **Role:** Public REST API endpoints handling triage requests, polling, SSE streaming, and health checks. Enforces strict JWT tenant authentication and rate-limiting.
### 8. Async Worker Service
- **Technology:** Celery + Redis
- **Role:** Manages deferred background tasks such as nightly ChromaDB backup pushes to Cloudflare R2, model cards fairness evaluations, and cache sweeps.
### 9. Platform Observability
- **Technology:** OpenTelemetry, Prometheus, Grafana Cloud, Langfuse, LangSmith, Sentry
- **Role:** Distributed tracking. Metrics collector publishes custom JVM/App metrics (18 signals, 5 dashboards). Langfuse parses token-level prompt performance.
---
## LangGraph Multi-Agent Architecture
Triage processing uses a LangGraph supervisor orchestrating six distinct sub-agents:
```text
+-----------------------+
| LangGraph Supervisor |
+-----------+-----------+
|
+-------------------+-------------------+
| | |
+------v-------+ +------v-------+ +------v-------+
|Classify Agent| | Memory Agent | | RAG Agent |
+------+-------+ +------+-------+ +------+-------+
| | |
+-------------------+-------------------+
|
+-------------------+-------------------+
| | |
+------v-------+ +------v-------+ +------v-------+
| Churn Agent | |Incident Agent| | HITL Agent |
+--------------+ +--------------+ +--------------+
```
1. **Classify Agent:** Classifies tickets and evaluates initial priority.
2. **Memory Agent:** Interacts with Mem0 using Supabase pgvector to load previous tenant/customer history.
3. **RAG Agent:** Performs hybrid vector/keyword searches on product guides and draft responses.
4. **Churn Agent:** Calculates customer churn risk flags from Gold mart metrics.
5. **Incident Agent:** Detects ongoing service incidents and schedules escalation workflows.
6. **HITL (Human-in-the-Loop) Agent:** Pauses graph execution using state checkpointers if safety limits are broken, saving state for manual human review.
---
## Deployment Modes
CustomerCore is designed to support three distinct operational topologies:
| Mode | Target | Infrastructure | Inference Engine |
|---|---|---|---|
| **Lite** | Development / Testing | Docker Compose (FastAPI, Redis, Chroma) | OpenRouter LLM Cloud API |
| **Full Local** | Production Simulation | 3-Node Kind Kubernetes Cluster | Local Ollama + GPU (RTX 3050 Ti) |
| **Cloud** | Production / Portfolio | Hugging Face Spaces (Docker), Cloudflare R2, Upstash Redis, Supabase DB | Cloud API / OpenRouter |
|