-
Notifications
You must be signed in to change notification settings - Fork 0
/
mqtt_publish.py
44 lines (36 loc) · 1.06 KB
/
mqtt_publish.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
#!/bin/python3
from paho.mqtt import client as mqtt_client
import time
from math import sin
broker = 'ec2-3-81-115-170.compute-1.amazonaws.com'
port = 2883
topic = "service/ansible/asdf"
client_id = f'python-mqtt-001'
def connect_mqtt() -> mqtt_client:
def on_connect(client, userdata, flags, rc):
if rc == 0:
print("Connected to MQTT Broker!")
else:
print("Failed to connect, return code %d\n", rc)
client = mqtt_client.Client(client_id)
client.on_connect = on_connect
client.connect(broker, port)
return client
def publish(client):
msg_count = 0
while True:
msg = f"test,tag1=1,tag2=2 value={sin(msg_count/10)}"
result = client.publish(topic, msg)
status = result[0]
if status == 0:
print(f"Send `{msg}` to topic `{topic}`")
else:
print(f"Failed to send message to topic {topic}")
msg_count += 1
time.sleep(0.1)
def run():
client = connect_mqtt()
client.loop_start()
publish(client)
if __name__ == '__main__':
run()