Skip to content
Snippets Groups Projects
Select Git revision
  • 911cb6c779e93ddc76a9f4d5f0e9f05789814f36
  • main default protected
  • add_export_route
  • add_route_assignments
  • 4.1.0-dev
  • 4.0.0
  • 3.5.3
  • 3.5.3-dev
  • 3.5.2
  • 3.5.2-dev
  • 3.5.1
  • 3.5.1-dev
  • 3.5.0
  • 3.4.2
  • 3.4.1
  • 3.4.0
  • 3.3.0
  • 3.2.0
  • 3.1.3
  • 3.1.2
  • 3.1.1
  • 3.1.0
  • 3.0.1
  • 3.0.0
24 results

Session.ts

Blame
  • Forked from Dojo Project (HES-SO) / Projects / Backend / DojoBackendAPI
    Source project has a limited visibility.
    publisher.py 546 B
    import paho.mqtt.client as mqtt
    import os
    import time
    
    def on_connect(client, userdata, flags, rc):
        if rc==0:
            print("Connection Successful! Returned code =",rc)
        else:
            print("Unable to Connect. Returned code =", rc)
    
    def sender(client):
        while True:
            client.publish('comms', 'MQTT Secret Message')
            print('Published on topic comms')
            time.sleep(10)
    
    if __name__ == "__main__":
        client = mqtt.Client()
        client.on_connect = on_connect
    
        client.connect('broker', 1883, 60)
    
        sender(client)