Python--定时任务
2021-04-09 本文已影响0人
GG_lyf
前言
好久没更新过博客了,最近在忙一些学习上的事,这几天总有一个想法,老早之前写过的一些Python脚本都是一次性或是只能通过接口间接执行的。我会在想,如果当时我刚好不能上网,但是我想执行我的脚本,这可怎么办?接口名也那么长,我总不能直接记住吧!我的大脑容量也不够啊!把它们都记在手机上?不太现实!我写的大都是解析网页的脚本,总不能一直通过接口访问吧?这时,定时任务就是个好的帮手!
开搞
1.装python解析器都会吧!
2.重点是flask_apscheduler
这个库,这个库就是用来进行定时任务的,不管你是通过cmd
还是pycharm装都行
pycharm 提取码: 6sx4
注:这个pycharm是免安装的,直接解压就能用,并且还是汉化过的,请各位带哥自行取用,,用的时候只要指定自己的解析器就行
3.使用它
3.1必须先引入
from flask import Flask # 用来进行web接口的编写和启动
from flask_apscheduler import APScheduler # 定时任务的库
3.2指明要启动的方法名,并注册定时任务
app = Flask(__name__)
scheduler = APScheduler() # 注册定时任务
3.3在启动方法中使用
if __name__ == "__main__":
scheduler.init_app(app) # 初始化
scheduler.add_job(func=job, trigger='interval', seconds=2, id='job_id', kwargs={"i": "job_id"})
#各参数说明:方法名 触发器 时间间隔 标识id 方法需要的参数
#APScheduler提供了三种任务触发器:
#data:固定日期触发器:任务只运行一次,运行完毕自动清除;若错过指定运行时间,任务不会被创建
#interval:时间间隔触发器
#cron:cron风格的任务触发
scheduler.start() # 开启
app.run(host='0.0.0.0', port="8080") # web接口的地址和端口
3.4写方法
def job(i):
print(str(i))
l = test()
print(l)
if len(l) > 20:
scheduler.remove_job(id="job_id")
arr1 = [] # 这个全局数组是用来返回数据从而提供定时任务停止的条件
def test():
for i in range(5):
if i % 2 == 0:
arr1.append(i)
return arr1
3.5结果如下
还行
全部代码如下:
from flask import Flask
from flask_apscheduler import APScheduler
import datetime, os
app = Flask(__name__)
scheduler = APScheduler()
def write_log(buf):
print(buf)
with open('test.txt', 'a') as f:
f.write(buf + "\n")
@app.route("/test", methods=['GET', 'POST'])
def index():
return "hello world"
def job(i):
print(str(i))
l = test()
print(l)
write_log(str(l) + " " + str(datetime.datetime.now()))
if len(l) > 20:
scheduler.remove_job(id="job_id")
arr1 = []
def test():
for i in range(5):
if i % 2 == 0:
arr1.append(i)
return arr1
if __name__ == "__main__":
scheduler.init_app(app)
scheduler.add_job(func=job, trigger='interval', seconds=2, id='job_id', kwargs={"i": "job_id"})
# 各参数说明:方法名 触发器 时间间隔 标识id 方法需要的参数
# APScheduler提供了三种任务触发器:
# data:固定日期触发器:任务只运行一次,运行完毕自动清除;若错过指定运行时间,任务不会被创建
# interval:时间间隔触发器
# cron:cron风格的任务触发
scheduler.start()
app.run(host='0.0.0.0', port="8080")