Permalink
Switch branches/tags
Nothing to show
Find file Copy path
Fetching contributors…
Cannot retrieve contributors at this time
36 lines (31 sloc) 1.35 KB
from AWSIoTPythonSDK.MQTTLib import AWSIoTMQTTClient
import paho.mqtt.client as mqtt
import json
#aws configuration
awsClient = AWSIoTMQTTClient("multitech-gateway")
awsClient.configureEndpoint("a3m9jbp3s169k0.iot.us-east-1.amazonaws.com", 8883)
awsClient.configureCredentials("/home/walid/loramote/root-CA.crt", "/home/walid/loramote/conduit.private.key", "/home/walid/loramote/conduit.cert.pem")
awsClient.configureOfflinePublishQueueing(-1) # Infinite offline Publish queueing
awsClient.configureDrainingFrequency(2) # Draining: 2 Hz
awsClient.configureConnectDisconnectTimeout(10) # 10 sec
awsClient.configureMQTTOperationTimeout(5) # 5 sec
def on_message(client, userdata, msg):
print(msg.topic+" "+str(msg.payload))
#push message to aws
#create a new message which includes the topic and a the payload
message = {
'payload': msg.payload,
'topic': msg.topic
}
awsClient.publish(msg.topic, json.dumps(message), 0)
subscribed = False
def on_connect(localClient, userdata, flags, rc):
print("Connected to local mqtt server")
if subscribed == False:
localClient.subscribe("#")
awsClient.connect()
localClient.on_message = on_message
localClient = mqtt.Client()
localClient.on_connect = on_connect
localClient.connect("localhost", 1883, 60)
localClient.loop_forever()