使用云雀气象仪助力物联网可视化气象站 简单

#  -*- coding: UTF-8 -*-

# MindPlus
# Python
import sys
sys.path.append("/root/mindplus/.lib/thirdExtension/liliang-yunque-thirdex")
from DFRobot_Atmospherlum import *
from pinpong.board import Board
from unihiker import GUI
import time
import siot

# 事件回调函数
def on_message_callback(client, userdata, msg):
    if (msg.topic == "siot/报告消息"):
        s_message.config(text=(str(time.strftime("%H:%M:%S")) + str((str("：") + str(msg.payload.decode())))))

siot.init(client_id="16698909563024067",server="10.1.2.3",port=1883,user="siot",password="dfrobot")
Board().begin()
u_gui=GUI()
siot.connect()
siot.loop()
siot.set_callback(on_message_callback)
siot.getsubscribe(topic="siot/报告消息")
yunque_i2c = DFRobot_Atmospherlum_I2C(0x42)
while (yunque_i2c.begin() != 0):
    print("yunque_i2c initialize failed!")
    time.sleep(1)
print("Sensor initialize end!")
yunque_i2c.set_local_time()
time.sleep(1)

u_gui.draw_text(text="物联网可视化云雀\n气象仪数据发送端",x=20,y=10,font_size=15, color="#0000FF")
s_temp=u_gui.draw_text(text="",x=0,y=80,font_size=13, color="#0000FF")
s_speed=u_gui.draw_text(text="",x=0,y=130,font_size=13, color="#0000FF")
s_pressure=u_gui.draw_text(text="",x=0,y=180,font_size=13, color="#0000FF")
s_message=u_gui.draw_text(text="暂无消息",x=0,y=230,font_size=13, color="#0000FF")
s_time=u_gui.draw_text(text=time.strftime("%Y/%m/%d %H:%M:%S"),x=0,y=280,font_size=13, color="#0000FF")

while True:
    temp=yunque_i2c.get_value("Temp");humi=yunque_i2c.get_value("Humi");speed=yunque_i2c.get_value("Speed");dir=yunque_i2c.get_value("Dir");pressure=yunque_i2c.get_value("Pressure")
    # 以上代码的作用：将云雀气象仪采集的数据赋值给变量。
    s_temp.config(text="温湿度："+temp+'℃,'+humi+'%.');s_speed.config(text="风速和风向：{}m/s,{}方向。".format(speed,dir));s_pressure.config(text="大气压强：{}hpa。".format(pressure));s_time.config(text=time.strftime("%Y/%m/%d %H:%M:%S"))
    # 该代码将云雀气象仪的采集数据显示在行空板上。
    siot.publish_save(topic="siot/温度", data=temp)
    siot.publish_save(topic="siot/湿度", data=humi)
    siot.publish_save(topic="siot/温湿度", data=(str(temp) + str((str(",") + str(humi)))))
    siot.publish_save(topic="siot/风速", data=speed)
    siot.publish_save(topic="siot/风向", data=dir)
    siot.publish_save(topic="siot/大气压强", data=pressure)
    time.sleep(300)