测试时间

write_redis/a-crontab的任务

@@ -5,13 +5,13 @@
 10 * * * * cd /root/zhangbo/rov-offline && /bin/sh alg_recsys_recall_tags_videos_task.sh > my_logs_tags/tags_$(date +\%Y-\%m-\%d_\%H).log 2>&1
 16 * * * * cd /root/zhangbo/rov-offline/write_redis && /bin/sh alg_recsys_feature_02_vidhasreturnrov_redis_task.sh > my_logs_alg_recsys_feature_02_vidhasreturnrov_redis_task/$(date +\%Y-\%m-\%d_\%H_\%M).log 2>&1
 32 * * * * cd /root/zhangbo/rov-offline/write_redis && /bin/sh alg_recsys_rank_item_realtime_1h_task.sh > my_logs_alg_recsys_rank_item_realtime_1h_task/$(date +\%Y-\%m-\%d_\%H_\%M).log 2>&1
-25 * * * * cd /root/zhangbo/rov-offline/write_redis && /bin/sh alg_recsys_feature_03_vidhasreturnrov1d7d_redis_task.sh > my_logs_alg_recsys_feature_03_vidhasreturnrov1d7d_redis/$(date +\%Y-\%m-\%d_\%H_\%M).log 2>&1
-22 * * * * cd /root/zhangbo/rov-offline/write_redis && /bin/sh alg_recsys_feature_04_vidvov1d3d_redis_task.sh > my_logs_alg_recsys_feature_04_vidvov1d3d_redis/$(date +\%Y-\%m-\%d_\%H_\%M).log 2>&1
-13 05 * * * cd /root/zhangbo/rov-offline/write_redis && /bin/sh alg_recsys_feature_05_vidvovdaily4filter_redis_task.sh > my_logs_alg_recsys_feature_05/$(date +\%Y-\%m-\%d_\%H_\%M).log 2>&1
+#25 * * * * cd /root/zhangbo/rov-offline/write_redis && /bin/sh alg_recsys_feature_03_vidhasreturnrov1d7d_redis_task.sh > my_logs_alg_recsys_feature_03_vidhasreturnrov1d7d_redis/$(date +\%Y-\%m-\%d_\%H_\%M).log 2>&1
+#22 * * * * cd /root/zhangbo/rov-offline/write_redis && /bin/sh alg_recsys_feature_04_vidvov1d3d_redis_task.sh > my_logs_alg_recsys_feature_04_vidvov1d3d_redis/$(date +\%Y-\%m-\%d_\%H_\%M).log 2>&1
+#13 05 * * * cd /root/zhangbo/rov-offline/write_redis && /bin/sh alg_recsys_feature_05_vidvovdaily4filter_redis_task.sh > my_logs_alg_recsys_feature_05/$(date +\%Y-\%m-\%d_\%H_\%M).log 2>&1
 40 * * * * cd /root/zhangbo/rov-offline/write_redis && /bin/sh alg_recsys_task_doudi_videos_task.sh > my_logs_alg_recsys_task_doudi_videos/$(date +\%Y-\%m-\%d_\%H_\%M).log 2>&1
 22 * * * * cd /root/zhangbo/rov-offline/write_redis && /bin/sh alg_recsys_feature_06_vovhour4rank_redis_task.sh > my_logs_alg_recsys_feature_06_vovhour4rank_redis/$(date +\%Y-\%m-\%d_\%H_\%M).log 2>&1
 
-16 * * * * cd /root/zhangbo/rov-offline/write_redis && /bin/sh alg_recsys_feature_07_vidh24pred_redis_task.sh > my_logs_07/$(date +\%Y-\%m-\%d_\%H_\%M).log 2>&1
+28 * * * * cd /root/zhangbo/rov-offline/write_redis && /bin/sh alg_recsys_feature_07_vidh24pred_redis_task.sh > my_logs_07/$(date +\%Y-\%m-\%d_\%H_\%M).log 2>&1
 
 
 

write_redis/alg_recsys_feature_07_vidh24pred_redis.py

@@ -143,7 +143,7 @@ def main():
     begin_ts = int(time.time())
     table_data_cnt = 0
     while run_flag:
-        if int(time.time()) - begin_ts >= 60 * 40:
+        if int(time.time()) - begin_ts >= 60 * 1:
             log_.info("等待上游数据超过40分钟了，认为失败退出:过了{}秒。".format(int(time.time()) - begin_ts))
             sys.exit(1)
         table_data_cnt = check_data(project, table, date, hour)
@@ -177,7 +177,7 @@ if __name__ == '__main__':
 
 
 # cd /root/zhangbo/rov-offline
-# python alg_recsys_feature_07_vidh24pred_redis.py 20241023 18
+# python alg_recsys_feature_07_vidh24pred_redis.py 20241023 23
 
 """
     ！！！！！！！！！！！！！！ -----按小时更新-----