GEO-INFER-IOT

Instructions

Core Capabilities

• MQTT ingestion: Real paho-mqtt connection lifecycle management
• Streaming: Async sensor data pipelines
• Quality control: Spatial validation, outlier detection, data completeness
• Device management: Sensor registry, health monitoring
• Protocol support: MQTT, HTTP webhooks, WebSocket

Key Imports

from geo_infer_iot.core.ingestion import MQTTIngestionEngine
from geo_infer_iot.core.quality_control import SpatialQualityChecker
from geo_infer_iot.core.device_management import DeviceRegistry

Examples

from geo_infer_iot.core.ingestion import MQTTIngestionEngine

engine = MQTTIngestionEngine(broker="mqtt.example.com", port=1883)
engine.subscribe("sensors/temperature/#")

@engine.on_message
def handle_temperature(topic, payload):
    lat, lng = payload["location"]
    temp = payload["value"]
    print(f"Sensor at ({lat}, {lng}): {temp}°C")

engine.start()

from geo_infer_iot.core.quality_control import SpatialQualityChecker

checker = SpatialQualityChecker(bounds=(-90, -180, 90, 180))
clean_data = checker.validate(raw_readings)
print(f"Passed: {len(clean_data.valid)}, Rejected: {len(clean_data.outliers)}")

Guidelines

• MQTT handlers use real paho-mqtt (not placeholders)
• Spatial validation includes real geometry checks
• Optional deps load via try/except with lightweight fallback adapters for graceful degradation
• Test: uv run python -m pytest GEO-INFER-IOT/tests/ -v

Integrations

• DATA → Sensor data feeds into ETL pipelines
• TIME → Time-series analysis of sensor streams
• SPACE → Spatial indexing of sensor locations
• OPS → Monitoring sensor health and uptime
• COMMS → Alert broadcasting on sensor thresholds