|
@@ -1909,6 +1909,7 @@ class PoolRecall(object):
|
|
record_key_prefix=record_key_prefix,
|
|
record_key_prefix=record_key_prefix,
|
|
pool_key_prefix=pool_key_prefix,
|
|
pool_key_prefix=pool_key_prefix,
|
|
last_video_key_prefix=last_video_key_prefix)
|
|
last_video_key_prefix=last_video_key_prefix)
|
|
|
|
+ print("recall_name:", key_flag,"last_video_key_prefix:", last_video_key_prefix, "idx:", idx)
|
|
if not pool_key:
|
|
if not pool_key:
|
|
return []
|
|
return []
|
|
recall_data = []
|
|
recall_data = []
|
|
@@ -1967,7 +1968,7 @@ class PoolRecall(object):
|
|
last_video_key = f'{last_video_key_prefix}{self.app_type}:{self.mid}'
|
|
last_video_key = f'{last_video_key_prefix}{self.app_type}:{self.mid}'
|
|
self.redis_helper.set_data_to_redis(key_name=last_video_key, value=recall_data[-1][0],
|
|
self.redis_helper.set_data_to_redis(key_name=last_video_key, value=recall_data[-1][0],
|
|
expire_time=expire_time)
|
|
expire_time=expire_time)
|
|
- print("update recall_data:", key_flag, "last_video_key_prefix:", last_video_key_prefix)
|
|
|
|
|
|
+ print("update recall_data:", key_flag, "last_video_key_prefix:", last_video_key_prefix,"\t", recall_data[-1][0])
|
|
|
|
|
|
# log_.info({
|
|
# log_.info({
|
|
# 'logTimestamp': int(time.time() * 1000),
|
|
# 'logTimestamp': int(time.time() * 1000),
|