update

utils/sql_help.py

@@ -8,14 +8,14 @@ class sqlCollect():
     @classmethod
     def select_hour_data(cls):
 
-        sql = """SELECT video_id, video_title
+        sql = """SELECT video_id, video_title, create_time
                 FROM crawler_video
                 WHERE create_time >= DATE_SUB(NOW(), INTERVAL 1 HOUR)
                   AND create_time < NOW() AND video_title LIKE '%早%';"""
         try:
             data = MysqlHelper.get_values(sql)
             if data:
-                data_list = [{"video_id": row[0], "video_title": row[1]} for row in data]
+                data_list = [{"video_id": row[0], "video_title": row[1], "create_time": str(row[2])} for row in data]
                 return data_list
             return None
         except Exception as e:

workers/consumption_spider_work.py

@@ -6,9 +6,9 @@ from apscheduler.schedulers.asyncio import AsyncIOScheduler
 from apscheduler.triggers.cron import CronTrigger
 from loguru import logger
 
-from utils.gpt4o_mini_help import GPT4oMini
 
 sys.path.append('/app')
+from utils.gpt4o_mini_help import GPT4oMini
 from utils.piaoquan import PQ
 from utils.redis import RedisHelper, content_video_data
 

workers/select_spider_work.py

@@ -5,10 +5,9 @@ import time
 import schedule
 from loguru import logger
 
-from utils.sql_help import sqlCollect
 
 sys.path.append('/app')
-
+from utils.sql_help import sqlCollect
 from utils.redis import RedisHelper