Real-Time Semantic Data Pipeline

Async staged pipeline (ingest → normalize → entity-link → enrich → publish) that turns raw, inconsistent telemetry into a live, queryable semantic layer — consumed by an example rule-based decision agent whose reasoning trace (facts read, rule fired) is shown live on the dashboard.