上传温湿度数据

硬件连接

1. 准备DHT11传感器设备。
   
2. 将传感器接入到树莓派的主板。
   传感器拥有四个引脚，从左往右依次是VCC供电、数据、空、GND负极。由于数据脚需要上拉电平支持，所以我们需要使用一个额外的10 KΩ电阻连接VCC与数据管脚，具体连接如下图。
   接入后的效果图如下所示。

安装依赖程序

传感器的数据传递功能需要安装依赖程序开启。

1. 在命令窗口执行以下命令，完成程序安装。

   cd /home/pi/Desktop
   sudo apt update
   sudo apt install git
   git clone https://github.com/adafruit/Adafruit_Python_DHT.git
   cd Adafruit_Python_DHT
   sudo python3 setup.py install
   cd /

2. 继续执行以下命令，测试传感器是否已经工作正常。

   python3
   import Adafruit_DHT
   humidity, temperature = Adafruit_DHT.read_retry(11, 4)
   humidity,temperature

   如果传感器连接并且工作正常，会返回正确的温度与湿度数据。

修改和验证源码程序

您需要修改树莓派计算机的源码程序文件，将新属性（机房温度、机房湿度）数据添加到协议字段中。

1. 修改源码程序文件run.py。
   程序文件run.py的修改方法请参见将树莓派接入物联网平台。

   说明 不需要重新下载源码压缩包，直接修改已下载解压的程序文件即可。

   请对比以下内容修改run.py文件并保存。

   #!/usr/bin/python3
   
   import aliLink,mqttd,rpi
   import time,json
   import Adafruit_DHT
   
   
   # 三元素（iot后台获取）
   ProductKey = '***'
   DeviceName = 'raspberrypi4-******'
   DeviceSecret = "assef***"
   # topic (iot后台获取)
   POST = '/sys/***/raspberrypi4-***/thing/event/property/post'  # 上报消息到云
   POST_REPLY = '/sys/***/raspberrypi4-***/thing/event/property/post_reply'  
   SET = '/sys/***/raspberrypi4-***/thing/service/property/set'  # 订阅云端指令
   
   
   # 消息回调（云端下发消息的回调函数）
   def on_message(client, userdata, msg):
       #print(msg.payload)
       Msg = json.loads(msg.payload)
       switch = Msg['params']['PowerLed']
       rpi.powerLed(switch)
       print(msg.payload)  # 开关值
   
   #连接回调（与阿里云建立链接后的回调函数）
   def on_connect(client, userdata, flags, rc):
       pass
   
   # 链接信息
   Server,ClientId,userNmae,Password = aliLink.linkiot(DeviceName,ProductKey,DeviceSecret)
   
   # mqtt链接
   mqtt = mqttd.MQTT(Server,ClientId,userNmae,Password)
   mqtt.subscribe(SET) # 订阅服务器下发消息topic
   mqtt.begin(on_message,on_connect)
   
   
   # 信息获取上报，每10秒钟上报一次系统参数
   while True:
       time.sleep(10)
       #获取指示灯状态
       power_stats=int(rpi.getLed())
       if(power_stats==0):
           power_LED = 0
       else:
           power_LED = 1
   
       # CPU 信息
       CPU_temp = float(rpi.getCPUtemperature())  # 温度   ℃
       CPU_usage = float(rpi.getCPUuse())         # 占用率 %
   
       # RAM 信息
       RAM_stats =rpi.getRAMinfo()
       RAM_total =round(int(RAM_stats[0]) /1000,1)  
       RAM_used =round(int(RAM_stats[1]) /1000,1)
       RAM_free =round(int(RAM_stats[2]) /1000,1)
   
       # Disk 信息
       DISK_stats =rpi.getDiskSpace()
       DISK_total = float(DISK_stats[0][:-1])
       DISK_used = float(DISK_stats[1][:-1])
       DISK_perc = float(DISK_stats[3][:-1])
   
       # 获取传感器信息
       humidity, temperature = Adafruit_DHT.read_retry(11, 4)
       # 构建与云端模型一致的消息结构
       updateMsn = {
           'cpu_temperature':CPU_temp,
           'cpu_usage':CPU_usage,
           'RAM_total':RAM_total,
           'RAM_used':RAM_used,
           'RAM_free':RAM_free,
           'DISK_total':DISK_total,
           'DISK_used_space':DISK_used,
           'DISK_used_percentage':DISK_perc,
           'PowerLed':power_LED,
           'temperature':temperature,
           'humidity':humidity
       }
       JsonUpdataMsn = aliLink.Alink(updateMsn)
       print(JsonUpdataMsn)
   
       mqtt.push(POST,JsonUpdataMsn) # 定时向阿里云IOT推送我们构建好的Alink协议数据

2. 重启服务。
   在命令行窗口执行以下命令。

   cd /home/pi/Desktop/code/
   python3 run.py

   数据结果如图所示。
3. 在IoT平台查询上报的数据。
   前往设备详情页，单击物模型数据 > 运行状态，查看新增的机房温度和湿度数据。