[esp8266_micropython] 读取dht11温湿度数据并通过mqtt上报

mao_jin_dao

代码

1. import dht
   
2. from machine import Pin
   
3. import time
   
4. import network
   
5. from umqtt.simple import MQTTClient
   
6. import json
   
7. import gc
   
8. 
   
9. 
   
10. device_id = "esp0002"
    
11. wifi_ssid='FAST_20CC'
    
12. wifi_password='409409409'
    
13. mqtt_serverip='192.168.1.113'
    
14. mqtt_serverport=1883
    
15. mqtt_clientid=device_id
    
16. mqtt_publishtopic=b'espiot'
    
17. 
    
18. led=Pin(2,Pin.OUT)
    
19. led.on()
    
20. 
    
21. # D2-DATA
    
22. dht_sim = dht.DHT11(Pin(4))
    
23. 
    
24. def connectionWifi(ssid, password):
    
25.   wlan = network.WLAN(network.STA_IF)
    
26.   wlan.active(True)
    
27.   wlan.connect(ssid, password)
    
28.   while True:
    
29.     if not wlan.isconnected():
    
30.       led.on()
    
31.       time.sleep_ms(1000)
    
32.       led.off()
    
33.       time.sleep_ms(1000)
    
34.     else:
    
35.       print('connected to network')
    
36.       led.on()
    
37.       break
    
38. 
    
39. def dht11_temperature():
    
40.   dht_sim.measure()
    
41.   return dht_sim.temperature()
    
42.   
    
43. def dht11_humidity():
    
44.   dht_sim.measure()
    
45.   return dht_sim.humidity()
    
46. 
    
47. if __name__=='__main__':
    
48.   print ("start")
    
49.   
    
50.   #message_template="{'source_device':'$source_device','target_device':'server','temperature':'$temperature'}"
    
51.   #message_template = message_template.replace("$source_device",mqtt_clientid)
    
52.   message_template = {}
    
53.   message_template['source_device'] = mqtt_clientid
    
54.   message_template['target_device'] = 'server'
    
55.   message_template['msg_type'] = 'ReportTempHumi'
    
56.   
    
57.   connectionWifi(wifi_ssid,wifi_password)
    
58.   
    
59.   client = MQTTClient(mqtt_clientid,mqtt_serverip,mqtt_serverport)
    
60.   client.connect()
    
61.   
    
62.   
    
63.   while True:
    
64.     time.sleep(3)
    
65.    
    
66.     temperature = dht11_temperature()
    
67.     message_template['temperature'] = str(temperature)
    
68.    
    
69.     humidity = dht11_humidity()
    
70.     message_template['humidity'] = str(humidity)
    
71.    
    
72.     client.publish(mqtt_publishtopic,json.dumps(message_template))
    
73. 
    
74.     gc.collect()

复制代码

截图

zhonsir

怎么mqtt数据中没有看到温度数据

mao_jin_dao

zhonsir 发表于 2023-7-15 13:19
怎么mqtt数据中没有看到温度数据

1. {
   
2.   "temperature": "37",
   
3.   "source_device": "esp0002",
   
4.   "humidity": "43",
   
5.   "target_device": "server",
   
6.   "msg_type": "ReportTempHumi"
   
7. }

复制代码

temperature字段是温度
humidity字段是湿度

茶壹杯

  做的很好

不知mqtt server是怎么搭的？

pldjn

mqtt是怎么样工作的，我一直没搞清楚