Skip to content

F
ffm-baseline
Commit d53d71ef authored by 高雅喆's avatar 高雅喆
Browse files
Options

update

parent cba514a8
Show whitespace changes
Inline Side-by-side
Showing with 4 additions and 4 deletions
eda/smart_rank/dist_periodic_update_smart_rank.py
View file @ d53d71ef
......@@ -29,8 +29,8 @@ def update_device_smart_rank(device_id, result_all_dict, service_detail_view_cou
device_meigou_smart_rank.update({service_id: meigou_smart_rank_score})
device_meigou_smart_rank_key = 'device_meigou_smart_rank:device_id:' + str(device_id)
# cli_ins.hmset(device_meigou_smart_rank_key, device_meigou_smart_rank)
# cli_ins.expire(device_meigou_smart_rank_key, time=24 * 60 * 60)
cli_ins.hmset(device_meigou_smart_rank_key, device_meigou_smart_rank)
cli_ins.expire(device_meigou_smart_rank_key, time=24 * 60 * 60)
return meigou_smart_rank_score
return "periodic update fail"
......@@ -182,8 +182,8 @@ if __name__ == '__main__':
cli_ins = redis.StrictRedis.from_url(REDIS_URL)
gray_level_device_ids = "doris:ctr_estimate:device_id_list"
if cli_ins.exists(gray_level_device_ids):
# device_ids = cli_ins.smembers(gray_level_device_ids)
device_ids = [b"9C5E7C73-380C-4623-8F48-A64C8034E315" for i in range(1000)]
device_ids = cli_ins.smembers(gray_level_device_ids)
# device_ids = [b"9C5E7C73-380C-4623-8F48-A64C8034E315" for i in range(1000)]
device_ids_rdd = spark.sparkContext.parallelize(device_ids)
result = device_ids_rdd.repartition(40).map(
lambda x: update_device_smart_rank(str(x, encoding='utf-8'), result_all_dict,
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment