|
@@ -2670,22 +2670,22 @@ class PoolRecall(object):
|
|
|
if not mid:
|
|
if not mid:
|
|
|
return []
|
|
return []
|
|
|
recall_key = "u2i:"+mid
|
|
recall_key = "u2i:"+mid
|
|
|
- #print("recall_key:", recall_key)
|
|
|
|
|
|
|
+ print("recall_key:", recall_key)
|
|
|
data = self.redis_helper.get_data_from_redis(key_name=recall_key)
|
|
data = self.redis_helper.get_data_from_redis(key_name=recall_key)
|
|
|
|
|
|
|
|
- #print(data)
|
|
|
|
|
|
|
+ print(data)
|
|
|
recall_result = []
|
|
recall_result = []
|
|
|
recall_dict = {}
|
|
recall_dict = {}
|
|
|
video_ids = []
|
|
video_ids = []
|
|
|
if data is not None:
|
|
if data is not None:
|
|
|
json_result = json.loads(data)
|
|
json_result = json.loads(data)
|
|
|
- # print("json_result:", json_result)
|
|
|
|
|
|
|
+ print("json_result:", json_result)
|
|
|
for per_item in json_result:
|
|
for per_item in json_result:
|
|
|
try:
|
|
try:
|
|
|
vid = int(per_item[0])
|
|
vid = int(per_item[0])
|
|
|
video_ids.append(vid)
|
|
video_ids.append(vid)
|
|
|
recall_dict[vid] = {'videoId': vid, 'flowPool': '',
|
|
recall_dict[vid] = {'videoId': vid, 'flowPool': '',
|
|
|
- 'rovScore': per_item[1], 'pushFrom': config_.PUSH_FROM['hot_recall'],
|
|
|
|
|
|
|
+ 'rovScore': per_item[1], 'pushFrom': config_.PUSH_FROM['u2i_tag_recall'],
|
|
|
'abCode': self.ab_code}
|
|
'abCode': self.ab_code}
|
|
|
except Exception as e:
|
|
except Exception as e:
|
|
|
continue
|
|
continue
|
linfan