48 lines
1.1 KiB
Python
48 lines
1.1 KiB
Python
|
import time
|
||
|
|
from umqtt.simple import MQTTClient
|
||
|
|
|
||
|
|
|
||
|
|
import network
|
||
|
|
import time
|
||
|
|
from math import sin
|
||
|
|
|
||
|
|
# Received messages from subscriptions will be delivered to this callback
|
||
|
|
def sub_cb(topic, msg):
|
||
|
|
print((topic, msg))
|
||
|
|
|
||
|
|
|
||
|
|
def main(server="192.168.1.59"):
|
||
|
|
# Fill in your WiFi network name (ssid) and password here:
|
||
|
|
wifi_ssid = "OddlyAsus"
|
||
|
|
wifi_password = "8699869986"
|
||
|
|
|
||
|
|
# Connect to WiFi
|
||
|
|
wlan = network.WLAN(network.STA_IF)
|
||
|
|
wlan.active(True)
|
||
|
|
wlan.connect(wifi_ssid, wifi_password)
|
||
|
|
while wlan.isconnected() == False:
|
||
|
|
print('Waiting for connection...')
|
||
|
|
time.sleep(1)
|
||
|
|
print("Connected to WiFi")
|
||
|
|
|
||
|
|
c = MQTTClient("pico_board", server, 1883)
|
||
|
|
c.set_callback(sub_cb)
|
||
|
|
c.connect()
|
||
|
|
c.subscribe(b"godot/#")
|
||
|
|
while True:
|
||
|
|
if True:
|
||
|
|
# Blocking wait for message
|
||
|
|
c.wait_msg()
|
||
|
|
else:
|
||
|
|
# Non-blocking wait for message
|
||
|
|
c.check_msg()
|
||
|
|
# Then need to sleep to avoid 100% CPU usage (in a real
|
||
|
|
# app other useful actions would be performed instead)
|
||
|
|
time.sleep(1)
|
||
|
|
|
||
|
|
c.disconnect()
|
||
|
|
|
||
|
|
|
||
|
|
if __name__ == "__main__":
|
||
|
|
main()
|