APScheduler定时任务

Posted 2020-12-13 marier

import psutil
from apscheduler.schedulers.blocking import BlockingScheduler
from threading import Timer
import datetime

def System_text():
# 获取cpu使用情况
cpu = psutil.cpu_percent()
# 获取内存使用情况：系统内存大小，使用内存，有效内存，内存使用率
mem = psutil.virtual_memory()
memper = mem.percent
now_time = datetime.datetime.now()
ts = now_time.strftime(‘%Y-%m-%d %H:%M:%S‘)
line = f‘{ts} cpu:{cpu}% mem:{memper}%‘
print(line)
# Timer(1, System_text).start()定时器

def System_text1():
print(‘暴富于‘,datetime.datetime.now())
# Timer(1, System_text1).start()

def Job_time():
# apscheduler定时任务框架
# 1 > triggers（触发器）：触发器包含调度逻辑，每一个作业有它自己的触发器
# 2 > jobstores（作业存储）:用来存储被调度的作业，默认的作业存储器是简单地把作业任务保存在内存中, 支持存储到MongoDB，Redis数据库中
# 3 > executors（执行器）：执行器用来执行定时任务，只是将需要执行的任务放在新的线程或者线程池中运行
# 4 > schedulers（调度器）：调度器是将其它部分联系在一起, 对使用者提供接口，进行任务添加，设置，删除。
scheduler = BlockingScheduler()
scheduler.add_job(System_text,‘interval‘,seconds=1)
scheduler.add_job(System_text1,‘interval‘,seconds=3)
scheduler.start()

if name == ‘main‘:
Job_time()