4、设备接入与数据上云（二）：设备SDK集成（Python/Java）、设备端代码编写、属性上报与事件上报

好，咱们接着上一章往下聊。上一节我们把设备在阿里云IoT平台上注册好了，也拿到了三元组。那接下来要干什么？说白了，就是让设备真正“开口说话”。

这一节，我带你手把手把设备SDK集成进去，然后写代码让设备上报属性和事件。嗯，这部分是实战中的硬骨头，也是你后面所有可视化大屏的数据来源。搞不定这一步，后面全是空中楼阁。

4.1 设备SDK选型与集成

阿里云IoT平台提供了多种语言的SDK。我个人最常用的是Python和Java。为什么？Python适合快速原型验证，Java适合生产环境的高并发场景。

先说说Python SDK。你可以在GitHub上找到阿里云官方的Python SDK仓库，叫aliyun-iot-linkkit。安装很简单：

pip install aliyun-iot-linkkit

Java SDK呢？我建议用Maven或者Gradle引入。在pom.xml里加这个依赖：

<dependency>
    <groupId>com.aliyun.iot</groupId>
    <artifactId>aliyun-iot-sdk-linkkit</artifactId>
    <version>2.3.0</version>
</dependency>

4.2 设备端代码编写——Python版

好，咱们先写Python版本的设备端代码。你想想看，一个设备要连上云，核心就三步：初始化、连接、上报。

先看初始化部分：

from aliyun_iot_linkkit import LinkKit
import time

# 设备三元组
product_key = "你的ProductKey"
device_name = "你的DeviceName"
device_secret = "你的DeviceSecret"

# 初始化LinkKit
lk = LinkKit(
    product_key=product_key,
    device_name=device_name,
    device_secret=device_secret
)

嗯，这里要注意。三元组千万别硬编码在代码里。我在项目中吃过这个亏——代码不小心传到GitHub上，三元组直接暴露了。后来我改成从环境变量或者配置文件读取。

接下来是连接和回调：

def on_connect(session_flag, user_data):
    print("设备连接成功！")
    # 连接成功后，可以开始上报数据

def on_disconnect(reason, user_data):
    print("设备断开连接，原因：", reason)

lk.on_connect = on_connect
lk.on_disconnect = on_disconnect

lk.connect_async()
time.sleep(2)  # 等待连接完成

4.3 属性上报——让设备“说话”

属性上报，说白了就是告诉云端“我现在是什么状态”。比如温度传感器上报当前温度值。

代码其实很简单：

# 构造属性数据
properties = {
    "Temperature": 25.6,
    "Humidity": 60.2
}

# 上报属性
lk.post_property(properties)

你可能会问：属性名怎么来的？还记得我们在上一章创建产品时定义的属性吗？对，就是那个。属性名必须和产品模型里定义的一模一样，大小写都不能错。

我建议你写一个循环，定时上报：

import random

while True:
    # 模拟传感器数据
    temp = round(random.uniform(20.0, 30.0), 1)
    hum = round(random.uniform(40.0, 70.0), 1)
    
    properties = {
        "Temperature": temp,
        "Humidity": hum
    }
    
    lk.post_property(properties)
    print(f"上报属性：温度={temp}°C, 湿度={hum}%")
    
    time.sleep(5)  # 每5秒上报一次

4.4 事件上报——告诉云端“出事了”

属性上报是常态数据，事件上报则是异常或告警。比如温度超过阈值、设备掉线等。

事件上报的代码和属性上报类似，但多了一个事件标识符：

# 构造事件数据
event_data = {
    "Temperature": 35.8,
    "Message": "温度过高告警！"
}

# 上报事件
lk.post_event("HighTemperatureAlarm", event_data)

这里的HighTemperatureAlarm就是你在产品模型中定义的事件标识符。同样，必须完全匹配。

我一般会在代码里加一个判断逻辑：

if temp > 35.0:
    event_data = {
        "Temperature": temp,
        "Message": f"温度{temp}°C超过阈值35°C"
    }
    lk.post_event("HighTemperatureAlarm", event_data)
    print("触发高温告警事件！")

4.5 Java版设备端代码

好，Python版讲完了，咱们看看Java版。Java的写法稍微啰嗦一点，但逻辑是一样的。

先初始化：

import com.aliyun.iot.linkkit.LinkKit;
import com.aliyun.iot.linkkit.LinkKitCallback;

// 设备三元组
String productKey = "你的ProductKey";
String deviceName = "你的DeviceName";
String deviceSecret = "你的DeviceSecret";

// 初始化
LinkKit linkKit = LinkKit.getInstance();
linkKit.init(productKey, deviceName, deviceSecret);

连接和回调：

linkKit.setCallback(new LinkKitCallback() {
    @Override
    public void onConnect() {
        System.out.println("设备连接成功！");
    }
    
    @Override
    public void onDisconnect() {
        System.out.println("设备断开连接！");
    }
});

linkKit.connect();

属性上报：

Map<String, Object> properties = new HashMap<>();
properties.put("Temperature", 25.6);
properties.put("Humidity", 60.2);

linkKit.postProperty(properties);

事件上报：

Map<String, Object> eventData = new HashMap<>();
eventData.put("Temperature", 35.8);
eventData.put("Message", "温度过高告警！");

linkKit.postEvent("HighTemperatureAlarm", eventData);

4.6 避坑指南与最佳实践

最后，我总结几个实战中容易踩的坑：

• 三元组别写死： 用配置文件或环境变量。我曾经把三元组硬编码，结果代码泄露后设备被恶意控制。
• 上报频率控制： 别超过产品限制。一般免费版每秒最多上报10次。
• 数据格式校验： 属性值类型必须匹配。比如定义的是int，你传string就会失败。
• 网络重连机制： 设备断网后要自动重连。SDK默认有重连机制，但建议自己加一个心跳检测。

嗯，这一节的内容就到这。你回去把Python和Java的代码都跑一遍，看看能不能在IoT Studio的设备管理页面看到实时上报的数据。下一节，我们讲设备端如何接收云端下发的指令——也就是属性设置和服务调用。到时候你会看到，设备不仅能“说”，还能“听”。