video_rewriting/job_keyword_dy.py

import time

import schedule

from common import Material
from common.sql_help import sqlCollect

from video_rewriting.video_processor import VideoProcessor
def video_task_start():
    """抖视频搜索处理视频任务，返回用户名并根据结果决定延迟时间"""
    data = Material.feishu_list()[14]
    try:
        count = sqlCollect.get_channel_count("抖音搜索", "品类关键词搜索")
        count = int(count[0][0])
        sheet_count = Material.get_count_restrict("抖音关键词搜索")
        if sheet_count:
            if count >= int(sheet_count):
                print(f"到了限制数{count}")
                return
        print("开始执行任务")
        mark = VideoProcessor.main(data)
        print(f"返回用户名: {mark}")
        # time.sleep(10 if mark else 120)  # 根据 mark 是否为空设置延迟
    except Exception as e:
        print("处理任务时出现异常:", e)
        time.sleep(10)
        return
def schedule_tasks():
    schedule.every(10).minutes.do(video_task_start)
if __name__ == '__main__':
    schedule_tasks()  # 调用任务调度函数
    while True:
        schedule.run_pending()
        time.sleep(1)  # 每秒钟检查一次