robin2015
11/13/2019 - 9:15 AM

定时任务 python scheduler


def all_thread_action():

    scheduler = BackgroundScheduler()

    # 交易日 更新
    jiao_yi_ri_cache_action()
    trigger1 = CronTrigger(hour='00', minute='00', second='10')
    scheduler.add_job(id='cache_jiaoyiri', func=jiao_yi_ri_cache_action, trigger=trigger1, jitter=10, max_instances=6)

    # token auth 更新
    token_auth_thread_action()
    token_trigger = CronTrigger(second='*/5')
    scheduler.add_job(id='update_token_auth', func=token_auth_thread_action, trigger=token_trigger, max_instances=10)

    # 市场分析
    trigger2 = CronTrigger(day_of_week='mon-fri', hour='9-15', second='*/3')
    scheduler.add_job(id='cache_shichangfenxi', func=shi_chang_fen_xi_cache_action, trigger=trigger2, max_instances=10)

    # 资金记录
    trigger3 = CronTrigger(day_of_week='mon-fri', hour='9-15', second='*/3')
    scheduler.add_job(id='cache_zijinjilu', func=zi_jin_ji_lu_cache_action, trigger=trigger3, max_instances=10)

    # 板块 领涨股
    trigger4 = CronTrigger(day_of_week='mon-fri', hour='9-15', second='*/3')
    scheduler.add_job(id='cache_lingzhanggu', func=ling_zhang_gu_cache_action, trigger=trigger4, max_instances=10)

    # 板块 科创板
    trigger5 = CronTrigger(day_of_week='mon-fri', hour='9-15', second='*/2')
    scheduler.add_job(id='cache_kechuangban', func=ke_chuang_ban_cache_action, trigger=trigger5, max_instances=10)

    scheduler.start()

    timer_01 = threading.Timer(10, ling_zhang_gu_cache_action)  # 领涨股, 收盘时间启动时,10秒后执行一次
    timer_01.start()

    timer_02 = threading.Timer(10, shi_chang_fen_xi_cache_action)  # 市场分析, 收盘时间启动时,10秒后执行一次
    timer_02.start()

    timer_03 = threading.Timer(10, zi_jin_ji_lu_cache_action)  # 资金记录, 收盘时间启动时,10秒后执行一次
    timer_03.start()

    timer_04 = threading.Timer(10, ke_chuang_ban_cache_action)  # 科创板, 收盘时间启动时,10秒后执行一次
    timer_04.start()