import network
import time
import json
from machine import Pin,ADC
from time import sleep
from umqtt.simple import MQTTClient
#connecting the controller with internet
pot1=Pin(34)
pot=ADC(pot1)
print("connecting to internet")
sta=network.WLAN(network.STA_IF)
sta.active(True)
sta.connect('Wokwi-GUEST','')
while not sta.isconnected():
print(".",end="")
time.sleep(0.2)
print("connected")
#declaring constant
mqtt_bro="broker.hivemq.com"
mqtt_port=1883
mqtt_topic="temp"
client_id="suga"
#mqtt instance
mqtt=MQTTClient(client_id,mqtt_bro,port=mqtt_port)
#function for connecting mqtt
def conn_mqtt():
try:
print("connecting MQTT")
mqtt.connect()
except Exception as e:
print("exception due to",str(e))
conn_mqtt()
while True:
sleep(2)
val=str(pot,read())
mqtt.publish(mqtt_topic,val)
print("published" + val+"topic temp")