Update architecture.md
This commit is contained in:
parent
40b8256cad
commit
83f6b19865
@ -1,81 +1,68 @@
|
|||||||
|
# Cognitive AI Manufacturing Agent (IoT Industry Automation)
|
||||||
|
|
||||||
|
```mermaid
|
||||||
graph TB
|
graph TB
|
||||||
%% IoT Sensors
|
|
||||||
subgraph "IoT Sensors"
|
subgraph "IoT Sensors"
|
||||||
A1[Temp/Pressure/Vibration<br/>Flow/Speed/Level]
|
A[Temp/Pressure/Vibration<br/>Flow/Speed/Level/Current]
|
||||||
end
|
end
|
||||||
|
|
||||||
%% Edge Processing
|
|
||||||
subgraph "Edge Layer"
|
subgraph "Edge Layer"
|
||||||
B1[Edge Gateway<br/>Data Validation]
|
B[Edge Gateway & MQTT<br/>Data Validation/Protocol Convert]
|
||||||
B2[MQTT Broker<br/>Protocol Convert]
|
|
||||||
end
|
end
|
||||||
|
|
||||||
%% Stream Processing
|
|
||||||
subgraph "DataStreamX"
|
subgraph "DataStreamX"
|
||||||
C1[Real-time Ingestion]
|
C[Stream Processing<br/>Pattern Detection/Enrichment]
|
||||||
C2[Pattern Detection]
|
|
||||||
C3[Data Enrichment]
|
|
||||||
end
|
end
|
||||||
|
|
||||||
%% Event Streaming
|
subgraph "Kafka Streaming"
|
||||||
subgraph "Kafka"
|
D[Event Topics & Consumers<br/>sensor-data/alerts/commands]
|
||||||
D1[Event Topics<br/>sensor-data/alerts]
|
|
||||||
D2[Consumer Groups]
|
|
||||||
end
|
end
|
||||||
|
|
||||||
%% AI Engine
|
subgraph "AI Engine"
|
||||||
subgraph "AI Processing"
|
E[Node.js/Python Agents<br/>Anomaly/Predictive/ML]
|
||||||
E1[Anomaly Detection]
|
F[Decision & Rule Engine<br/>Action Classification]
|
||||||
E2[Predictive Maintenance]
|
|
||||||
E3[Decision Engine]
|
|
||||||
end
|
end
|
||||||
|
|
||||||
%% Actions
|
|
||||||
subgraph "Actions"
|
subgraph "Actions"
|
||||||
F1{Critical?}
|
G{Critical Alert?}
|
||||||
F2[Emergency Stop]
|
H[Emergency Shutdown]
|
||||||
F3[Auto-Fix]
|
I[Auto-Fix & Control]
|
||||||
F4[Optimization]
|
J[Optimization]
|
||||||
end
|
end
|
||||||
|
|
||||||
%% Notifications
|
subgraph "HookPilot Automation"
|
||||||
subgraph "HookPilot"
|
K[Webhook Receiver<br/>Workflow Engine]
|
||||||
G1[Workflow Engine]
|
L[Multi-channel Dispatch<br/>Template/Retry/APIs]
|
||||||
G2[Multi-channel<br/>Telegram/Email/Slack]
|
end
|
||||||
|
|
||||||
|
subgraph "Notifications"
|
||||||
|
M[Telegram/Email/Slack<br/>SMS/WhatsApp/Push]
|
||||||
end
|
end
|
||||||
|
|
||||||
%% Dashboard
|
|
||||||
subgraph "React Dashboard"
|
subgraph "React Dashboard"
|
||||||
H1[Real-time Monitor]
|
N[Real-time Monitor<br/>Analytics/Control Panel]
|
||||||
H2[Analytics]
|
|
||||||
H3[Control Panel]
|
|
||||||
end
|
end
|
||||||
|
|
||||||
%% Storage
|
subgraph "Storage & Analytics"
|
||||||
subgraph "Storage"
|
O[Time Series/Event Store<br/>Config/User/ML Models]
|
||||||
I1[Time Series DB]
|
|
||||||
I2[Event Store]
|
|
||||||
end
|
end
|
||||||
|
|
||||||
%% Learning Loop
|
subgraph "Learning Loop"
|
||||||
subgraph "ML Loop"
|
P[Performance Metrics<br/>Model Retraining/Tuning]
|
||||||
J1[Performance Metrics]
|
|
||||||
J2[Model Retraining]
|
|
||||||
end
|
end
|
||||||
|
|
||||||
%% Connections
|
A --> B --> C --> D
|
||||||
A1 --> B1 --> B2 --> C1
|
D --> E --> F --> G
|
||||||
C1 --> C2 --> C3 --> D1
|
G -->|Yes| H
|
||||||
D1 --> D2 --> E1
|
G -->|No| I --> J
|
||||||
E1 --> E2 --> E3 --> F1
|
H --> K
|
||||||
F1 -->|Yes| F2
|
I --> K
|
||||||
F1 -->|No| F3 --> F4
|
J --> K
|
||||||
F2 --> G1
|
K --> L --> M
|
||||||
F3 --> G1
|
D --> N
|
||||||
F4 --> G1
|
F --> N
|
||||||
G1 --> G2
|
N --> I
|
||||||
D2 --> H1 --> H2
|
C --> O
|
||||||
H3 --> F3
|
F --> O
|
||||||
C3 --> I1
|
N --> P --> E
|
||||||
E3 --> I2
|
```
|
||||||
H2 --> J1 --> J2 --> E1
|
|
||||||
Loading…
Reference in New Issue
Block a user