Annie

DynaRag — RAG System

MQTT metrics → cooldown → carousel AI → analysis republished

DynaRag — RAG System (v2026-08-28T093439Z-747172b178) 2026-08-28 | MQTT metrics → cooldown → carousel AI → analysis republished 1 - MQTT SUBSCRIPTION - receives metrics DynaRAGAnalyzer daemon/src/dynarag_analyzer.py mqtt_client.py dynarag/{topic}/metrics 2 - ANALYSIS - processes and analyzes metrics DynaRAGAnalyzer daemon/src/dynarag_analyzer.py httpx.AsyncClient GET /api/carousel/evaluate/ai POST /v1/messages 3 - PUBLISHING - publishes analysis results DynaRAGAnalyzer daemon/src/dynarag_analyzer.py mqtt_client.py dynarag/{topic}/analysis 1. Subscribes to MQTT 2. Receives metric data 3. Checks cooldown 4. Analyzes metrics 5. Calls Claude via Carousel 6. Publishes analysis Analysis Request Payload {"topic": "dynarag/cpu/metrics", "metric_type": "cpu_usage", "values": [75, 80, 85], "timestamps": ["2023-10-01T12:00:00… Analysis Result Payload {"topic": "dynarag/cpu/metrics", "timestamp": "2023-10-01T12:03:00Z", "analysis": "CPU usage is increasing steadily.", "… The system uses MQTT for real-time metric updates and analysis results. Cooldown is enforced to prevent excessive analysis requests. Legend actor = initiates work · process = code path · store = state on disk · bus = durable queue · dashed = separate process cyan = request flow · pink = state read/write · dashed green = pull / return path · red = refusal As of 2026-08-28 11:16 UTC, from commit 68470f5

Provenance

This drawing is generated, not drawn. It is rebuilt from the source files below, so when they change the picture changes — a diagram here cannot quietly describe a system that no longer works this way.

Owner
Annie
Slug
dynarag-rag-system
Rendered
2026-08-28T093439Z
From commit
747172b178
Updated
28 Aug 2026, 11:16 UTC
Sources at
68470f5
Watches
3 paths
  • daemon/src/dynarag_analyzer.py
  • tools/assistant
  • wordpress