System Architecture
graph TB
subgraph Data Sources
DG[Data Generator]
RT[Real Transactions]
end
subgraph Message Broker
K[Kafka]
end
subgraph Processing
PS[PySpark Processor]
N[Neo4j Graph DB]
end
subgraph ML Pipeline
GNN[GNN Model]
GR[GraphRAG]
end
subgraph Visualization
D[Dashboard]
end
DG -->|Synthetic Data| K
RT -->|Real Data| K
K -->|Stream| PS
PS -->|Processed Data| N
N -->|Graph Data| GNN
GNN -->|Predictions| GR
GR -->|Enhanced Results| D
N -->|Graph Queries| D
classDef active fill:#e1f5fe,stroke:#01579b,stroke-width:2px;
classDef inactive fill:#f5f5f5,stroke:#9e9e9e,stroke-width:1px;
classDef highlight fill:#fff3e0,stroke:#ef6c00,stroke-width:2px;