Untitled

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

# Параметры подключения к MQTT-брокеру
HOST = "192.168.2.23"  # IP чемодана
PORT = 1883  # Стандартный порт подключения для Mosquitto
KEEPALIVE = 60  # Время ожидания доставки сообщения, если при отправке оно будет превышено, брокер будет считаться недоступным

# Словарь с топиками и собираемыми из них параметрами
SUB_TOPICS = {
    '/devices/wb-m1w2_14/controls/External Sensor 1': 'temperature',
    '/devices/wb-msw-v3_21/controls/Sound Level': 'sound',
    '/devices/wb-msw-v3_21/controls/CO2': 'CO2',
    '/devices/wb-msw-v3_21/controls/Air Quality (VOC)': 'air quality'
}

JSON_LIST = []

# Создание словарей для хранения данных JSON и XML
JSON_DICT = {}
for value in SUB_TOPICS.values():
    JSON_DICT[value] = 0


def on_connect(client, userdata, flags, rc):
    print("Connected with result code " + str(rc))
    for topic in SUB_TOPICS.keys():
        client.subscribe(topic)


def on_message(client, userdata, msg):
    payload = msg.payload.decode()
    topic = msg.topic
    param_name = SUB_TOPICS[topic]

    JSON_DICT[param_name] = payload
    JSON_DICT['time'] = str(datetime.now())

    # Запись данных в JSON файл
    JSON_LIST.append(JSON_DICT.copy())
    with open('data.json', 'w') as json_file:  # Открываем файл для записи (перезаписываем)
        json_string = json.dumps(JSON_LIST, indent=4)  # Сериализуем JSON с отступами
        json_file.write(json_string)  # Записываем весь список JSON-объектов

def read_json_data(file_path):
    try:
        with open(file_path, 'r') as json_file:
            data = json.load(json_file)  # Загружаем JSON-данные
            print("JSON Data:")
            print(data)
    except FileNotFoundError:
        print(f"File {file_path} not found")

def main():
    client = mqtt.Client()
    client.on_connect = on_connect
    client.on_message = on_message
    client.connect(HOST, PORT, KEEPALIVE)
    client.loop_start()

    while True:
        read_json_data('data.json')
        time.sleep(5)

if __name__ == "__main__":
    main()