|
|
@@ -19,7 +19,7 @@ from video_capture.douyin.douyin_author.douyin_author import douyinAuthor
|
|
|
def get_account_id():
|
|
|
current_time = datetime.now()
|
|
|
formatted_time = current_time.strftime("%Y-%m-%d")
|
|
|
- count = f"""SELECT COUNT(*) AS total_count FROM ( SELECT audio, account_id FROM video_audio WHERE time = '{formatted_time}' GROUP BY audio, account_id) AS subquery;"""
|
|
|
+ count = f"""SELECT COUNT(*) AS total_count FROM ( SELECT audio, oss_object_key FROM video_audio WHERE time = '{formatted_time}' GROUP BY audio, oss_object_key) AS subquery;"""
|
|
|
print(count)
|
|
|
count = MysqlHelper.get_values(count, "prod")
|
|
|
return count
|
|
|
@@ -37,9 +37,10 @@ def job_video_stitching():
|
|
|
def job_douyin_data():
|
|
|
douyinAuthor.get_videoList()
|
|
|
|
|
|
-# 设置下午2点运行任务
|
|
|
-schedule.every().day.at("14:00").do(job_douyin_data)
|
|
|
+# 每5个小时执行一次
|
|
|
+schedule.every(5).hours.do(job_douyin_data)
|
|
|
|
|
|
+# 每15分钟执行一次
|
|
|
schedule.every(15).minutes.do(job_video_stitching)
|
|
|
|
|
|
while True:
|
