修复

write_redis/alg_recsys_rank_item_realtime_1h.py

@@ -28,8 +28,8 @@ redis_helper = RedisHelper()
 
 REDIS_PREFIX = "item_rt_fea_1h_"
 EXPIRE_TIME = 24 * 3600
-TIME_LIMIT_TABLE = 1
-TIME_LIMIT_TASK = 2
+TIME_LIMIT_TABLE = 40
+TIME_LIMIT_TASK = 60
 
 def worker(queue, executor):
     while True:

write_redis/alg_recsys_rank_item_realtime_1h_task.sh

@@ -23,4 +23,7 @@ echo "all done"
 
 
 
-# sh alg_recsys_rank_item_realtime_1h_task.sh
+# sh alg_recsys_rank_item_realtime_1h_task.sh
+
+
+#  02 * * * * 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

write_redis/utils_monitor.py

@@ -5,8 +5,6 @@ import sys
 root_dir = os.path.dirname(os.path.dirname(os.path.realpath(__file__)))
 if root_dir not in sys.path:
     sys.path.append(root_dir)
-    print("******** sys.path ********")
-    print(sys.path)
 
 from my_config import set_config
 from my_utils import send_msg_to_feishu