dict periodic update smart rank score

eda/smart_rank/dist_periodic_update_smart_rank.py

@@ -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,