import dht
from machine import Pin
import wifi
import time
from umqtt.simple import MQTTClient
d = dht.DHT22(Pin(12, Pin.IN))
wifi.connect_ap()
# Ket noi den broker
client_id = "c23ed05a75c42832cf982d06813066c9"
server = "broker.hivemq.com"
client = MQTTClient(client_id, server)
client.connect()
def loop():
while True:
d.measure()
temperature = d.temperature()
humidity = d.humidity()
# Gui len broker
print("Gui du lieu len broker")
client.publish("py_iot/nhiet_do", str(temperature) )
client.publish("py_iot/do_am", str(humidity))
time.sleep(5)
if __name__ == "__main__":
loop()
# d.measure()
# d.temperature()
# d.humidity()
# Kết nối internet => qua wifi
# Kết nối lên broker MQTT
# cứ 5s gửi dữ liệu lên 1 lần.