IIoT: подключение и аналитика

# Python скрипт для подключения температурного датчика к MQTT брокеру

import paho.mqtt.client as mqtt
import json
import time
import random
from datetime import datetime

class TemperatureSensor:
    def __init__(self, sensor_id, mqtt_broker, mqtt_port=1883):
        self.sensor_id = sensor_id
        self.client = mqtt.Client()
        self.client.on_connect = self.on_connect
        self.client.on_message = self.on_message
        
        # Подключение к MQTT брокеру
        self.client.connect(mqtt_broker, mqtt_port, 60)
        
    def on_connect(self, client, userdata, flags, rc):
        if rc == 0:
            print(f"Датчик {self.sensor_id} подключен к MQTT брокеру")
            # Подписка на команды управления
            client.subscribe(f"sensors/{self.sensor_id}/commands")
        else:
            print(f"Ошибка подключения: {rc}")
    
    def on_message(self, client, userdata, msg):
        command = msg.payload.decode()
        print(f"Получена команда: {command}")
        
    def read_temperature(self):
        # Симуляция чтения данных с датчика
        # В реальности здесь код работы с физическим датчиком
        temperature = round(random.uniform(20.0, 80.0), 2)
        return temperature
        
    def publish_data(self):
        temperature = self.read_temperature()
        
        # Формирование JSON сообщения
        data = {
            "sensor_id": self.sensor_id,
            "timestamp": datetime.now().isoformat(),
            "temperature": temperature,
            "unit": "Celsius",
            "location": "Производственный цех №1",
            "status": "OK" if 20 <= temperature <= 75 else "ALERT"
        }
        
        # Публикация данных
        topic = f"factory/temperature/{self.sensor_id}"
        self.client.publish(topic, json.dumps(data))
        print(f"Отправлены данные: {temperature}°C")
        
    def start_monitoring(self, interval=5):
        """Запуск циклического мониторинга с интервалом в секундах"""
        try:
            self.client.loop_start()
            while True:
                self.publish_data()
                time.sleep(interval)
        except KeyboardInterrupt:
            print("Мониторинг остановлен")
            self.client.loop_stop()
            self.client.disconnect()

# Пример использования
if __name__ == "__main__":
    # Создание экземпляра датчика
    sensor = TemperatureSensor(
        sensor_id="TEMP_001",
        mqtt_broker="192.168.1.100"  # IP адрес MQTT брокера
    )
    
    # Запуск мониторинга каждые 5 секунд
    sensor.start_monitoring(interval=5)