mqtt服务器数据写入数据库

import paho.mqtt.client as mqtt
import mysql.connector

# MQTT连接参数
mqtt_broker = "mqtt.example.com"
mqtt_port = 1883
mqtt_topic = "your/mqtt/topic"

# MySQL连接参数
mysql_host = "localhost"
mysql_user = "your_username"
mysql_password = "your_password"
mysql_database = "your_database"

# 连接到MQTT服务器
def on_connect(client, userdata, flags, rc):
    print("Connected to MQTT broker")
    client.subscribe(mqtt_topic)

# 处理接收到的MQTT消息
def on_message(client, userdata, msg):
    message = msg.payload.decode("utf-8")
    print("Received message: ", message)

    # 连接到MySQL数据库
    db = mysql.connector.connect(
        host=mysql_host,
        user=mysql_user,
        password=mysql_password,
        database=mysql_database
    )
    cursor = db.cursor()

    # 将消息写入数据库
    sql = "INSERT INTO your_table (message) VALUES (%s)"
    val = (message,)
    cursor.execute(sql, val)
    db.commit()

    # 关闭数据库连接
    cursor.close()
    db.close()

# 创建MQTT客户端
client = mqtt.Client()
client.on_connect = on_connect
client.on_message = on_message

# 连接到MQTT服务器
client.connect(mqtt_broker, mqtt_port, 60)

# 开始循环处理MQTT消息
client.loop_forever()