Spaces:
Sleeping
Sleeping
BioOps Team commited on
Commit ·
8f85a8b
1
Parent(s): 17e2e1f
Update MQTT broker to broker.hivemq.com
Browse files- README.md +3 -3
- bioops/industrial_edge/mqtt_client.py +2 -2
README.md
CHANGED
|
@@ -112,7 +112,7 @@ When enabled, all AI-generated commands are intercepted and require explicit ope
|
|
| 112 |
Every agent decision, operator command, and state transition is logged to an append-only JSONL file with ISO 8601 timestamps, source attribution, and severity levels.
|
| 113 |
|
| 114 |
### MQTT Edge Connectivity
|
| 115 |
-
Real-time telemetry is published to a configurable MQTT broker (`
|
| 116 |
|
| 117 |
### Statistical Anomaly Detection
|
| 118 |
A rolling Z-Score algorithm (window = 20 ticks) continuously monitors vibration data. When Z > 3σ, the system triggers visual alerts and injects a `SYSTEM_ALERT` into the LLM context to force recalibration.
|
|
@@ -127,7 +127,7 @@ bioops-twin/
|
|
| 127 |
├── app.py # Hugging Face Spaces entry point
|
| 128 |
├── requirements.txt
|
| 129 |
├── assets/
|
| 130 |
-
│ └──
|
| 131 |
├── data/
|
| 132 |
│ └── manuals/ # Calibration manual sources for RAG
|
| 133 |
├── bioops/
|
|
@@ -158,7 +158,7 @@ bioops-twin/
|
|
| 158 |
| Variable | Required | Description |
|
| 159 |
|----------|----------|-------------|
|
| 160 |
| `GEMINI_API_KEY` | No | Google Gemini API key. Without it, the agent runs in MOCK mode |
|
| 161 |
-
| `MQTT_BROKER` | No | MQTT broker host (default: `
|
| 162 |
| `MQTT_PORT` | No | MQTT broker port (default: `1883`) |
|
| 163 |
|
| 164 |
---
|
|
|
|
| 112 |
Every agent decision, operator command, and state transition is logged to an append-only JSONL file with ISO 8601 timestamps, source attribution, and severity levels.
|
| 113 |
|
| 114 |
### MQTT Edge Connectivity
|
| 115 |
+
Real-time telemetry is published to a configurable MQTT broker (`broker.hivemq.com` for demo), enabling integration with industrial SCADA/HMI systems and external monitoring tools like MQTT Explorer.
|
| 116 |
|
| 117 |
### Statistical Anomaly Detection
|
| 118 |
A rolling Z-Score algorithm (window = 20 ticks) continuously monitors vibration data. When Z > 3σ, the system triggers visual alerts and injects a `SYSTEM_ALERT` into the LLM context to force recalibration.
|
|
|
|
| 127 |
├── app.py # Hugging Face Spaces entry point
|
| 128 |
├── requirements.txt
|
| 129 |
├── assets/
|
| 130 |
+
│ └── centrifuge_v3.glb # 3D centrifuge model
|
| 131 |
├── data/
|
| 132 |
│ └── manuals/ # Calibration manual sources for RAG
|
| 133 |
├── bioops/
|
|
|
|
| 158 |
| Variable | Required | Description |
|
| 159 |
|----------|----------|-------------|
|
| 160 |
| `GEMINI_API_KEY` | No | Google Gemini API key. Without it, the agent runs in MOCK mode |
|
| 161 |
+
| `MQTT_BROKER` | No | MQTT broker host (default: `broker.hivemq.com`) |
|
| 162 |
| `MQTT_PORT` | No | MQTT broker port (default: `1883`) |
|
| 163 |
|
| 164 |
---
|
bioops/industrial_edge/mqtt_client.py
CHANGED
|
@@ -1,7 +1,7 @@
|
|
| 1 |
"""MQTT Edge Adapter for BioOps Twin.
|
| 2 |
|
| 3 |
Simulates industrial connectivity by publishing telemetry to a public
|
| 4 |
-
MQTT broker (e.g.,
|
| 5 |
so the local simulation does not crash if the broker is unavailable.
|
| 6 |
"""
|
| 7 |
|
|
@@ -15,7 +15,7 @@ import paho.mqtt.client as mqtt
|
|
| 15 |
logger = logging.getLogger("bioops_twin.mqtt")
|
| 16 |
|
| 17 |
# Public broker for demo purposes
|
| 18 |
-
MQTT_BROKER = "
|
| 19 |
MQTT_PORT = 1883
|
| 20 |
MQTT_TOPIC_TELEMETRY = "bioops/factory1/centrifuge1/telemetry"
|
| 21 |
MQTT_TOPIC_ALERTS = "bioops/factory1/centrifuge1/alerts"
|
|
|
|
| 1 |
"""MQTT Edge Adapter for BioOps Twin.
|
| 2 |
|
| 3 |
Simulates industrial connectivity by publishing telemetry to a public
|
| 4 |
+
MQTT broker (e.g., broker.hivemq.com). Includes a robust fallback
|
| 5 |
so the local simulation does not crash if the broker is unavailable.
|
| 6 |
"""
|
| 7 |
|
|
|
|
| 15 |
logger = logging.getLogger("bioops_twin.mqtt")
|
| 16 |
|
| 17 |
# Public broker for demo purposes
|
| 18 |
+
MQTT_BROKER = "broker.hivemq.com"
|
| 19 |
MQTT_PORT = 1883
|
| 20 |
MQTT_TOPIC_TELEMETRY = "bioops/factory1/centrifuge1/telemetry"
|
| 21 |
MQTT_TOPIC_ALERTS = "bioops/factory1/centrifuge1/alerts"
|