update

carry_data_redis.py

@@ -27,7 +27,7 @@ def bot_carry_data():
 def bot_nrfx_carry_data():
     try:
         logger.info(f"[+] 开始获取内容分析")
-        count = insert_carry_data(0, "task:carry_redis_by_nrfx",FS_SHEET, "内容分析")
+        count = insert_carry_data(0, "task:carry_redis_by_nrfx",FS_SHEET, "片尾引导")
         logger.info(f"[+] 开始获取内容分析共获取{count}条")
 
     except Exception as e:

carry_gz_nrfx_data_handle.py

@@ -43,7 +43,7 @@ def nrfx_video_task_start():
     except Exception as e:
         data = json.loads(data)
         in_carry_video_data("task:carry_redis_by_nrfx", json.dumps(data, ensure_ascii=False, indent=4))
-        AliyunLogger.logging(data["type"],"内容分析", data["channel"], data["videoid"], "视频处理失败,失败信息{e}", "3003", str(data))
+        AliyunLogger.logging(data["type"],"片尾引导", data["channel"], data["videoid"], "视频处理失败,失败信息{e}", "3003", str(data))
 
         logger.error(f"[+] {data}处理失败,失败信息{e}")
         return

common/redis.py

@@ -36,7 +36,7 @@ class SyncRedisHelper:
             self._pool.disconnect(inuse_connections=True)
 
 def insert_carry_data(dt, REDIS_NAME,FS_SHEET, NAME):
-    if NAME == "内容分析":
+    if NAME == "片尾引导":
         data = OdpsDataCount.main()
     else:
         data = Material.get_carry_data(dt, FS_SHEET,NAME)

docker-compose.yml

@@ -315,10 +315,10 @@ services:
     restart: unless-stopped
     environment:
       - ENV=prod
-      - FS_SHEET=Um1nWA
+      - FS_SHEET=1Ycd37
       - TASK_TYPE=redis
-      - NAME=内容分析
-      - REDIS_NAME=task:carry_redis_nrfx
+      - NAME=片尾引导
+      - REDIS_NAME=task:carry_redis_by_nrfx
     networks:
       - carry_net
     entrypoint: "python /app/carry_gz_nrfx_data_handle.py"