如何将IoT Central传感器数据导入MySQL数据库？Azure Functions实现咨询

1. 准备基础环境与资源 #

• 确保拥有Azure账号，创建一个Azure Functions应用（支持Python/.NET/Node.js等语言，以下以Python为例）
• 准备MySQL数据库（可选用Azure托管的MySQL服务，或自建实例）：
  • 若用Azure托管服务，需在防火墙规则中添加Functions的出站IP，或允许所有Azure服务访问
  • 自建实例需确保与Functions网络连通
• 在MySQL中创建对应数据表，示例SQL：

CREATE TABLE sensor_data (
    id INT AUTO_INCREMENT PRIMARY KEY,
    heart_rate INT,
    systolic_bp INT,
    diastolic_bp INT,
    temperature DECIMAL(5,2),
    timestamp DATETIME DEFAULT CURRENT_TIMESTAMP
);

（可根据传感器实际输出调整字段，比如合并血压字段）

2. 配置Functions触发方式 #

选择HTTP触发作为传感器数据的接入点：

• 在Functions应用中创建HTTP触发函数，根据安全需求设置访问权限（匿名或API密钥验证）
• 函数生成专属端点URL，传感器通过POST请求将JSON格式数据发送至此，示例请求体：

{
    "heart_rate": 75,
    "systolic_bp": 120,
    "diastolic_bp": 80,
    "temperature": 36.5
}

3. 编写Functions业务逻辑（Python示例） #

• 在函数代码文件（如__init__.py）中引入MySQL驱动，同时在requirements.txt添加依赖：

mysql-connector-python>=8.0.33
azure-functions>=1.17.0

• 编写数据接收与插入逻辑：

import mysql.connector
import azure.functions as func
import os

def main(req: func.HttpRequest) -> func.HttpResponse:
    try:
        # 解析请求体中的传感器数据
        req_body = req.get_json()
        heart_rate = req_body.get('heart_rate')
        systolic_bp = req_body.get('systolic_bp')
        diastolic_bp = req_body.get('diastolic_bp')
        temperature = req_body.get('temperature')

        # 从环境变量读取MySQL连接信息（禁止硬编码敏感信息）
        db_config = {
            'user': os.environ['MYSQL_USER'],
            'password': os.environ['MYSQL_PASSWORD'],
            'host': os.environ['MYSQL_HOST'],
            'database': os.environ['MYSQL_DB'],
            'port': int(os.environ['MYSQL_PORT'])
        }

        # 连接数据库并插入数据
        conn = mysql.connector.connect(**db_config)
        cursor = conn.cursor()
        insert_query = """
            INSERT INTO sensor_data (heart_rate, systolic_bp, diastolic_bp, temperature)
            VALUES (%s, %s, %s, %s)
        """
        cursor.execute(insert_query, (heart_rate, systolic_bp, diastolic_bp, temperature))
        conn.commit()
        cursor.close()
        conn.close()

        return func.HttpResponse("数据同步成功", status_code=200)
    except Exception as e:
        return func.HttpResponse(f"同步失败: {str(e)}", status_code=500)

4. 配置Functions环境变量 #

在Azure Functions应用的配置页面添加以下环境变量，避免代码硬编码敏感信息：

• MYSQL_USER: MySQL用户名
• MYSQL_PASSWORD: MySQL密码
• MYSQL_HOST: MySQL服务器地址（如xxx.mysql.database.azure.com）
• MYSQL_DB: 目标数据库名称
• MYSQL_PORT: 数据库端口（默认3306）

5. 测试与调试 #

• 用Postman或curl发送POST请求到函数端点，验证数据是否成功写入MySQL
• 若出现连接错误，检查MySQL防火墙规则、网络连通性及环境变量配置
• 通过Azure门户的监控->日志查看函数运行日志，排查异常

6. 传感器端适配 #

让模拟传感器发送符合格式的POST请求到Functions端点即可。若传感器不支持直接HTTP请求，可先将数据发送至Azure IoT Hub，再通过IoT Hub触发的Functions处理数据写入MySQL，更适配物联网场景。

内容的提问来源于stack exchange，提问作者melain