-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy path16_mqtt.py
53 lines (42 loc) · 1.62 KB
/
16_mqtt.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
# installiere umqtt.robust
# installiere umqtt.simple
import network
from machine import Pin
import utime
from time import sleep
import dht
dhtSensor = dht.DHT11(machine.Pin(16))
from umqtt.simple import MQTTClient
def verbinden():
rp2.country("DE") # Jedes Land hat andere Vorschiften für das W-Lan (z.B. Signalstärke, verfügbare Kanäle) und stellt diese entsprechend ein. Ist aber optional.
wlan = network.WLAN(network.STA_IF)
wlan.active(True)
wlan.connect("Gr.Hasenpfad_2.4", "robo-1958!")
# Der Aufbau einer Verbindung dauert eine Weile und es werden unterumständen mehrer Versuche benötigt bis eine Verbindung hergestellt wurde.
while not wlan.isconnected() and wlan.status() >= 0:
print("Verbinde, bitte warten...")
time.sleep(2) # Pause zwische 2 Verbindungsversuche
print(wlan.ifconfig())
print("Bin online...")
return wlan
# user von hivemq.com angelegt
# Name für serverless account: detlev.barthel, pw: Robo-1958"
def connectMQTT():
client = MQTTClient(client_id="pico_W_1",
server= b"bde1be3a9e954388b08a9aafcbda674a.s1.eu.hivemq.cloud",
port=0,
user="detlev.barthel",
password=b"Robo-1958!",
keepalive= 7200,
ssl=True,
)
def publish(topic, value):
print(topic)
print(value)
client.publish(topic, value)
print("publishing done")
verbinden()
client = connectMQTT()
while True:
pass
#sensor_reading =