diff --git a/utils/mqtt_rider_convert/mqtt_rider_convert.py b/utils/mqtt_rider_convert/mqtt_rider_convert.py index ce9db786..8f97a04a 100644 --- a/utils/mqtt_rider_convert/mqtt_rider_convert.py +++ b/utils/mqtt_rider_convert/mqtt_rider_convert.py @@ -68,3 +68,6 @@ def on_message(client, userdata, message): #print payload client.publish(channel, payload) + + # add to rider_cache rider's latest location + redis_conn.geoadd('loc_rider_active', rider_log, rider_lat, rider_id)