From d1b41ca36ce62b91221776879ec3f73e9efe40ab Mon Sep 17 00:00:00 2001 From: Korina Cordero Date: Tue, 23 Apr 2019 05:59:06 +0000 Subject: [PATCH] Save rider's coordinates into redis hash. #180 --- .../rider_location_cache.py | 22 +++++++++++++------ 1 file changed, 15 insertions(+), 7 deletions(-) diff --git a/utils/rider_location_cache/rider_location_cache.py b/utils/rider_location_cache/rider_location_cache.py index 0b4e85b6..d1a3de15 100644 --- a/utils/rider_location_cache/rider_location_cache.py +++ b/utils/rider_location_cache/rider_location_cache.py @@ -6,7 +6,6 @@ import time import signal import sys import os -import mysql.connector import json def init_subscriptions(client): @@ -30,6 +29,7 @@ def on_message(client, userdata, message): # check if json decodable res = json.loads(message.payload) + print res # get rider session id sess_id = message.topic[10:] @@ -42,12 +42,20 @@ def on_message(client, userdata, message): if res['event'] != 'driver_location': return + # save the longitude and latitude + # get the rider id from sess_id + rider_key = "rider.location.%s" % sess_id + rider_long = str(res['longitude']) + rider_lat = str(res['latitude']) + + # set the location + redis_conn.hmset(rider_key, {'longitude': rider_long, 'latitude': rider_lat}) + # update our redis key key = 'location_%s' % sess_id print "setting %s" % key redis_conn.setex(key, 1600, message.payload) - def sigint_handler(signal, frame): print 'Interrupted' sys.exit(0) @@ -65,10 +73,11 @@ redis_conn = redis.StrictRedis(host='localhost', port=6379, db=0) #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.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) #t = Thread(target=getRedis, args=(1,)) @@ -77,4 +86,3 @@ client.connect("resqaws.jankstudio.com", 8883, 60) #signal.signal(signal.SIGINT, sigint_handler) client.loop_forever() -