OffLineRec/import_redist.py

#coding utf-8
import sys
import json
from db_help import RedisHelper

if __name__=="__main__":
     with  open(sys.argv[1]) as f:
         rec_json_list=json.load(f)
         #print(rec_json_list)
         import_data_dict = {}
         for line in rec_json_list:
             #print(line)
             rec_list = line[1][:10]
             rec_item_list = []
             for rec_item in rec_list:
                 rec_item_list.append((rec_item[0], round(rec_item[1],3)))
             print(line[0]+"\t"+json.dumps(rec_item_list))
             key="sim_"+line[0]
             import_data_dict[key] = json.dumps(rec_item_list)
         redis_helper = RedisHelper()
         #redis_helper.update_batch_setnx_key(import_data_dict, 60*60*12)
         #con = redis_helper.connect()
         res = redis_helper.get_data_from_redis("sim_14330133")
         print(res)