update

carry_data_pw_redis.py

@@ -0,0 +1,34 @@
+import datetime
+import os
+import time
+
+import schedule
+from loguru import logger
+from common.redis import  insert_carry_data
+
+
+def bot_nrfx_carry_data():
+    try:
+        logger.info(f"[+] 开始获取内容分析")
+        count = insert_carry_data(0, "task:carry_redis_by_nrfx","", "片尾引导")
+        logger.info(f"[+] 开始获取内容分析共获取{count}条")
+
+    except Exception as e:
+        logger.error(f"[+] 获取内容分析失败，失败信息{e}")
+
+
+
+
+def schedule_tasks():
+    schedule.every().hour.at(":45").do(bot_nrfx_carry_data)
+
+
+
+if __name__ == "__main__":
+    # bot_nrfx_carry_data()
+    schedule_tasks()  # 调用任务调度函数
+    while True:
+        schedule.run_pending()
+        time.sleep(1)  # 每秒钟检查一次
+    # bot_carry_data()
+

carry_data_redis.py

@@ -24,21 +24,21 @@ def bot_carry_data():
         logger.error(f"[+] 获取{NAME},时区为{dt}失败，失败信息{e}")
 
 
-def bot_nrfx_carry_data():
-    try:
-        logger.info(f"[+] 开始获取内容分析")
-        count = insert_carry_data(0, "task:carry_redis_by_nrfx",FS_SHEET, "片尾引导")
-        logger.info(f"[+] 开始获取内容分析共获取{count}条")
-
-    except Exception as e:
-        logger.error(f"[+] 获取内容分析失败，失败信息{e}")
+# def bot_nrfx_carry_data():
+#     try:
+#         logger.info(f"[+] 开始获取内容分析")
+#         count = insert_carry_data(0, "task:carry_redis_by_nrfx",FS_SHEET, "片尾引导")
+#         logger.info(f"[+] 开始获取内容分析共获取{count}条")
+#
+#     except Exception as e:
+#         logger.error(f"[+] 获取内容分析失败，失败信息{e}")
 
 
 
 
 def schedule_tasks():
     schedule.every().hour.at(":05").do(bot_carry_data)
-    schedule.every().hour.at(":45").do(bot_nrfx_carry_data)
+    # schedule.every().hour.at(":45").do(bot_nrfx_carry_data)
 
 
 

docker-compose.yml

@@ -322,6 +322,21 @@ services:
     networks:
       - carry_net
     entrypoint: "python /app/carry_gz_nrfx_data_handle.py"
+  worker23:
+    depends_on:
+      - worker1
+    image: carry_data
+    container_name: carry_worker23
+    restart: unless-stopped
+    environment:
+      - ENV=prod
+      - FS_SHEET=1Ycd37
+      - TASK_TYPE=redis
+      - NAME=片尾引导
+      - REDIS_NAME=task:carry_redis_by_nrfx
+    networks:
+      - carry_net
+    entrypoint: "python /app/carry_data_pw_redis.py"
 networks:
   carry_net:
     name: carry_net