python 任务计时器　apscheduler.schedulers

Posted 2023-01-13

crontab 真的不好用

import pandas as pd
import subprocess
import os
import time
from datetime import datetime
from apscheduler.schedulers.blocking import BlockingScheduler
import logging
python_path = /home/game/anaconda3/bin/python



def train_and_restart():

    logging.error(start train model:.format(datetime.now()))
    os.system(/bin/bash /home/game/glory_deepfm1/AP/rec1/gcs_data.sh)

    #logging.error(update model weight to cloud storage:.format(datetime.now()))
    #os.system( update_weight.py>>train_log.txt.format(python_path))


if __name__ == __main__:
    hours = 2
    scheduler = BlockingScheduler()

    scheduler.add_job( train_and_restart, cron,hour= */2)
#    scheduler.add_job(train_and_restart, interval, hours = hours, next_run_time = datetime.now() + pd.Timedelta(hours = 0))
    scheduler.start()

~