调试

docker-compose.yml

@@ -85,6 +85,90 @@ services:
     networks:
       - google_net
     entrypoint: "python /app/advertisement_job.py"
+  worker8:
+    depends_on:
+      - worker1
+    image: google_ai_studio
+    container_name: google_worker8
+    restart: unless-stopped
+    environment:
+      - ENV=prod
+      - API_KEY=AIzaSyCntZuz-nyHi9bcKV09YWbBQRZJUkZvuQk
+      - TASK_TYPE=pq
+    networks:
+      - google_net
+  worker9:
+    depends_on:
+      - worker1
+    image: google_ai_studio
+    container_name: google_worker9
+    restart: unless-stopped
+    environment:
+      - ENV=prod
+      - API_KEY=AIzaSyC70ZbPtnIMuz94sofqx40fmgAuDyW4JV0
+      - TASK_TYPE=pq
+    networks:
+      - google_net
+  worker10:
+    depends_on:
+      - worker1
+    image: google_ai_studio
+    container_name: google_worker10
+    restart: unless-stopped
+    environment:
+      - ENV=prod
+      - API_KEY=AIzaSyD96zHr04SU7Ybn9BMkhIFHkh-kAf8Amtk
+      - TASK_TYPE=pq
+    networks:
+      - google_net
+  worker11:
+    depends_on:
+      - worker1
+    image: google_ai_studio
+    container_name: google_worker11
+    restart: unless-stopped
+    environment:
+      - ENV=prod
+      - API_KEY=AIzaSyApu2sAzvCeU84Te1FxVFjf2_Fe-zS0Vgo
+      - TASK_TYPE=pq
+    networks:
+      - google_net
+  worker12:
+    depends_on:
+      - worker1
+    image: google_ai_studio
+    container_name: google_worker12
+    restart: unless-stopped
+    environment:
+      - ENV=prod
+      - API_KEY=AIzaSyCcCrgmmjoifRMPRqXHHBKOsM5ButN1a4c
+      - TASK_TYPE=pq
+    networks:
+      - google_net
+  worker13:
+    depends_on:
+      - worker1
+    image: google_ai_studio
+    container_name: google_worker13
+    restart: unless-stopped
+    environment:
+      - ENV=prod
+      - API_KEY=AIzaSyCmLB67QIPwXznMnIe72vhyU-3wTPes_JU
+      - TASK_TYPE=pq
+    networks:
+      - google_net
+  worker14:
+    depends_on:
+      - worker1
+    image: google_ai_studio
+    container_name: google_worker14
+    restart: unless-stopped
+    environment:
+      - ENV=prod
+      - API_KEY=AIzaSyCOytzMj28Z2u8JXrzptACJp21qOapeasg
+      - TASK_TYPE=pq
+    networks:
+      - google_net
 networks:
   google_net:
     name: google_net

job_redis_data.py

@@ -18,6 +18,18 @@ def bot_video_ai_top():
         print(f"当日头部异常了{e}")
 
 
+def bot_video_ai_pq():
+    """票圈推荐个性化/标签体系/"""
+    try:
+        dt = datetime.datetime.now().strftime('%Y%m%d')
+        print(f"开始执行票圈推荐个性化{dt}")
+        redis_task = 'task:video_ai_pq'
+        table_name = 'history_top2000_add_aitags'
+        install_video_data(dt, redis_task, table_name)
+    except Exception as e:
+        print(f"票圈推荐个性化异常了{e}")
+
+
 def bot_video_ai_recommend():
     """新推荐"""
     try:
@@ -40,6 +52,7 @@ def ab_video_ai_recommend():
 
 def schedule_tasks():
     schedule.every().hour.at(":22").do(bot_video_ai_recommend)
+    schedule.every().day.at("02:25").do(bot_video_ai_pq)
     schedule.every().day.at("01:25").do(bot_video_ai_top)
     schedule.every().day.at("23:25").do(ab_video_ai_recommend)
 
@@ -51,4 +64,5 @@ if __name__ == "__main__":
         time.sleep(1)  # 每秒钟检查一次
     # ab_video_ai_recommend()
     # bot_video_ai_top()
-    # bot_video_ai_recommend()
+    # bot_video_ai_recommend()
+    # bot_video_ai_pq()