26 lines
783 B
Python
26 lines
783 B
Python
import paho.mqtt.client as mqtt
|
|
import rider_location_cache as rlc
|
|
import ssl
|
|
import redis
|
|
import logging
|
|
|
|
redis_client = redis.StrictRedis(host='localhost', port=6379, db=0)
|
|
userdata = {'redis': redis_client}
|
|
|
|
client = mqtt.Client("", True, userdata)
|
|
client.on_connect = rlc.on_connect
|
|
# client.on_publish = on_publish
|
|
client.on_message = rlc.on_message
|
|
|
|
#client.tls_set(
|
|
# "/etc/letsencrypt/live/resqaws.jankstudio.com/fullchain.pem", cert_reqs=ssl.CERT_NONE,
|
|
# tls_version=ssl.PROTOCOL_TLSv1)
|
|
#client.tls_set(
|
|
# "/root/aws_ssl_keys/fullchain.pem", cert_reqs=ssl.CERT_NONE,
|
|
# tls_version=ssl.PROTOCOL_TLSv1)
|
|
#client.connect("resqaws.jankstudio.com", 8883, 60)
|
|
client.connect("localhost", 1883, 60)
|
|
|
|
|
|
rider_location = rlc.RiderLocationCache()
|
|
rider_location.run(client)
|