Merge branch 'debug' into test

db_helper.py

@@ -272,9 +272,15 @@ class HologresHelper(object):
 
 if __name__ == '__main__':
     redis_helper = RedisHelper()
-    key = 'flow.video.12345.123#112'
+    # key = 'flow.video.12345.123#112'
     # redis_helper.decr_key(key_name=key)
     # res = redis_helper.get_data_from_redis(key_name=key)
     # print(int(res), type(int(res)))
-    data = redis_helper.get_data_zset_with_index(key_name=config_.BOTTOM_KEY_NAME, start=0, end=-1)
-    print(len(data))
+    # data = redis_helper.get_data_zset_with_index(key_name=config_.BOTTOM_KEY_NAME, start=0, end=-1)
+    # print(len(data))
+    # key_name = 'com.weiqu.video.hot.recommend.previewed.4.weixin_openid_otjoB5VG780SB4aVjYqBBNLb - X6M'
+    # values = (6134455, 9772930, 9912678, 9901969, 9926876, 9904203, 2384831, 9932272, 9737653, 9925240)
+    key_name = 'com.weiqu.video.hot.recommend.previewed.4.weixin_openid_otjoB5Q2b - PuUKPKVDLXMa62P_zU'
+    values = (9902612, 9905573, 9928264, 9932148, 9809440, 9919900, 6093379, 9917093, 9793537, 9814345)
+    redis_helper.add_data_with_set(key_name=key_name, values=values, expire_time=30 * 60)
+

recommend.py

@@ -80,7 +80,7 @@ def video_recommend(mid, uid, size, app_type, algo_type):
     # 预曝光数据同步刷新到Redis, 过期时间为0.5h
     redis_helper = RedisHelper()
     preview_key_name = config_.PREVIEW_KEY_PREFIX + '{}.{}'.format(app_type, mid)
-    preview_video_ids = [item['videoId'] for item in rank_result]
+    preview_video_ids = [int(item['videoId']) for item in rank_result]
     if preview_video_ids:
         log_.error('key_name = {} \n values = {}'.format(preview_key_name, tuple(preview_video_ids)))
         redis_helper.add_data_with_set(key_name=preview_key_name, values=tuple(preview_video_ids), expire_time=30*60)