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() ~