38 lines
925 B
Python
38 lines
925 B
Python
import paho.mqtt.client as mqtt
|
|
import time
|
|
|
|
def on_message(client, userdata, message):
|
|
|
|
lastMessage = userdata
|
|
|
|
currentTime = time.time()
|
|
#
|
|
print('ct - ' + str(currentTime))
|
|
print('lm - ' + str(lastMessage))
|
|
print('dif - ' + str(currentTime - lastMessage))
|
|
if currentTime - lastMessage > 15:
|
|
print(message.payload.decode())
|
|
client.publish("/repeat/", message.payload)
|
|
lastMessage = time.time()
|
|
client.user_data_set(lastMessage)
|
|
|
|
else:
|
|
print("too soon")
|
|
client.publish("/repeat/", "too soon test")
|
|
lastMessage = time.time()
|
|
client.user_data_set(lastMessage)
|
|
|
|
|
|
|
|
mqttBroker = 'icyn30.duckdns.org'
|
|
mqttPort = 1888
|
|
|
|
client = mqtt.Client("Notifier1", userdata=time.time())
|
|
|
|
client.connect(mqttBroker, mqttPort)
|
|
|
|
client.subscribe("/Test/test")
|
|
client.on_message = on_message
|
|
|
|
client.loop_forever()
|