rgutierrez/resq
1
0
Fork 0
Code Issues 126 Pull requests 49 Projects Releases 4 Packages Wiki Activity Actions

Save rider's coordinates into redis hash. #180

Browse source
This commit is contained in:
Korina Cordero 2019-04-23 05:59:06 +00:00
parent deff9b7f74
commit d1b41ca36c
1 changed files with 15 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

22
utils/rider_location_cache/rider_location_cache.py
View file

@ -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()