mqtt数据发送到mysql

要将 MQTT 数据发送到 MySQL 数据库，你可以使用以下步骤：

1. 首先，你需要在 MQTT 服务器和 MySQL 数据库之间建立连接。你可以使用 Python 中的 paho-mqtt 库来连接 MQTT 服务器，并使用 Python 的 MySQL Connector 库连接 MySQL 数据库。

2. 接下来，你需要订阅 MQTT 主题以接收数据。你可以使用 paho-mqtt 库来订阅主题。

3. 一旦你接收到 MQTT 数据，你可以使用 Python 的 MySQL Connector 库将数据插入到 MySQL 数据库中。

下面是一个示例代码，可以将 MQTT 数据发送到 MySQL 数据库：

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

# MQTT 服务器地址和端口
MQTT_BROKER = "mqtt.example.com"
MQTT_PORT = 1883

# MySQL 数据库配置
MYSQL_HOST = "localhost"
MYSQL_USER = "root"
MYSQL_PASSWORD = "password"
MYSQL_DATABASE = "test"

# MQTT 主题
MQTT_TOPIC = "/data"

# 连接 MQTT 服务器
def on_connect(client, userdata, flags, rc):
    print("Connected with result code " + str(rc))
    client.subscribe(MQTT_TOPIC)

# 接收 MQTT 消息并将其插入到 MySQL 数据库中
def on_message(client, userdata, msg):
    message = str(msg.payload.decode("utf-8"))
    print("Received message: " + message)

    # 连接 MySQL 数据库
    cnx = mysql.connector.connect(
        host=MYSQL_HOST,
        user=MYSQL_USER,
        password=MYSQL_PASSWORD,
        database=MYSQL_DATABASE
    )

    # 插入数据到 MySQL 数据库
    cursor = cnx.cursor()
    add_data = ("INSERT INTO data "
                "(value) "
                "VALUES (%s)")
    data = (message,)
    cursor.execute(add_data, data)
    cnx.commit()

    cursor.close()
    cnx.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()

在这个示例中，我们订阅了 `/data` 主题，当接收到消息时，将其插入到名为 `data` 的 MySQL 数据库中。你需要根据自己的实际情况修改代码中的 MQTT 服务器地址、MySQL 数据库配置和主题名称。