How to migrate from dallas DS18B01 to zigbee sensors

				
					#!/usr/bin/python
# -*- coding: utf-8 -*-
import json
import time
import mysql.connector
import paho.mqtt.client as mqtt

# --- DATABASE CONNECTION CONFIGURATION ---
DB_CONFIG = {
    'host': 'localhost',
    'user': 'Username',       # Replace with your actual database username
    'password': 'Password',   # Replace with your actual database name
    'autocommit': True
}

def update_db(sensor_name, temperature, epoch_time):
    """Executes a thread-safe upsert directly to the SQL server."""
    connection = None
    cursor = None
    try:
        connection = mysql.connector.connect(**DB_CONFIG)
        cursor = connection.cursor()

        query = """
            INSERT INTO sensors (sensor_name, temperature, last_seen)
            VALUES (%s, %s, %s)
            ON DUPLICATE KEY UPDATE
                temperature = VALUES(temperature),
                last_seen = VALUES(last_seen);
        """
        cursor.execute(query, (sensor_name, temperature, int(epoch_time)))

    except mysql.connector.Error:
        pass  # Suppress errors to allow seamless background execution
    finally:
        if cursor:
            cursor.close()
        if connection:
            connection.close()


# --- MQTT EVENT HANDLERS ---
def on_connect(client, userdata, flags, rc, properties=None):
    client.subscribe("zhub/data/#")

def on_message(client, userdata, msg):
    try:
        topic = msg.topic
        payload = json.loads(msg.payload.decode())

        parts = topic.split('/')
        if len(parts) < 3:
            return

        ieee_address = parts[2]
        current_time = time.time()

        # --- HARDWARE ADDR MAPPING ---
        # MQTT Name matches the exact destination SQL String key
        mapping = {
            "a4c138017da8ffff": "Exterior",
            "8c73dafffe28136f": "Sufragerie",
            "8c73dafffeb5eca2": "Dormitor",
            "e406bffffeabe170": "Hol",
            "e406bffffeabd436": "Pardoseala"
        }

        if ieee_address in mapping:
            sensor_name = mapping[ieee_address]

            # Validate cluster format specifically for Temperature Data (0402)
            if "0402" in parts and 'data' in payload and 'val' in payload['data']:
                temp_val = float(payload['data']['val'])

                # Commit data points instantly to SQL Server
                update_db(sensor_name, temp_val, current_time)
                print ("facem update in SQL")

    except Exception:
        pass  # Maintain daemon stability by handling exceptions silently


if __name__ == '__main__':
    client = mqtt.Client(mqtt.CallbackAPIVersion.VERSION2)
    client.on_connect = on_connect
    client.on_message = on_message

    try:
        client.connect("localhost", 1883, 60)
        client.loop_forever()
    except (KeyboardInterrupt, SystemExit):
        pass