vb net的定时循环_Python3-定时任务的四种实现方式
最近做一个小程序开发任务,主要负责后台部分开发;根据项目需求,需要实现三个定时任务:
1>定时更新微信token,需要2小时更新一次;
2>商品定时上线;
3>定时检测后台服务是否存活;
使用Python去实现这三个任务,这里需要使用定时相关知识点;
Python实现定点与定时任务方式比较多,找到下面四中实现方式,每个方式都有自己应用场景;下面来快速介绍Python中常用的定时任务实现方式:
1.循环+sleep;
2.线程模块中Timer类;
3.schedule模块;
4.定时框架:APScheduler
在开始之前先设定一个任务(这样不用依赖外部环境):
1:定时或者定点监测CPU与内存使用率;
2:将时间,CPU,内存使用情况保存到日志文件;
先来实现系统监测功能:
准备工作:安装psutil:pip install psutil
功能实现
#psutil:获取系统信息模块,可以获取CPU,内存,磁盘等的使用情况
import psutil
import time
import datetime
#logfile:监测信息写入文件
def MonitorSystem(logfile = None):
#获取cpu使用情况
cpuper = psutil.cpu_percent()
#获取内存使用情况:系统内存大小,使用内存,有效内存,内存使用率
mem = psutil.virtual_memory()
#内存使用率
memper = mem.percent
#获取当前时间
now = datetime.datetime.now()
ts = now.strftime('%Y-%m-%d %H:%M:%S')
line = f'{ts} cpu:{cpuper}%, mem:{memper}%'
print(line)
if logfile:
logfile.write(line)
代码运行结果:
2019-03-21 14:23:41 cpu:0.6%, mem:77.2%
接下来我们要实现定时监测,比如3s监测一下系统资源使用情况。
最简单使用方式:sleep
这种方式最简单,直接使用while+sleep就可以实现:
def loopMonitor():
while True:
MonitorSystem()
#2s检查一次
time.sleep(3)
loopMonitor()
输出结果:
2019-03-21 14:28:42 cpu:1.5%, mem:77.6%2019-03-21 14:28:45 cpu:1.6%, mem:77.6%2019-03-21 14:28:48 cpu:1.4%, mem:77.6%2019-03-21 14:28:51 cpu:1.4%, mem:77.6%2019-03-21 14:28:54 cpu:1.3%, mem:77.6%
这种方式存在问题:只能处理单个定时任务。
又来了新任务:需要每秒监测网络收发字节,代码实现如下:
def MonitorNetWork(logfile = None):
#获取网络收信息
netinfo = psutil.net_io_counters()
#获取当前时间
now = datetime.datetime.now()
ts = now.strftime('%Y-%m-%d %H:%M:%S')
line = f'{ts} bytessent={netinfo.bytes_sent}, bytesrecv={netinfo.bytes_recv}'
print(line)
if logfile:
logfile.write(line)
MonitorNetWork()
代码执行结果:
2019-03-21 14:47:21 bytessent=169752183, bytesrecv=1107900973
如果我们同时在while循环中监测两个任务会有等待问题,不能每秒监测网络情况。
Timer实现方式
timer最基本理解就是定时器,我们可以启动多个定时任务,这些定时器任务是异步执行,所以不存在等待顺序执行问题。
先来看Timer的基本使用:
导入:from threading import Timer
主要方法:
Timer方法说明Timer(interval, function, args=None, kwargs=None)创建定时器cancel()取消定时器start()使用线程方式执行join(self, timeout=None)等待线程执行结束
定时器只能执行一次,如果需要重复执行,需要重新添加任务;
我们先来看基本使用:
from threading import Timer
#记录当前时间
print(datetime.datetime.now())
#3S执行一次
sTimer = Timer(3, MonitorSystem)
#1S执行一次
nTimer = Timer(1, MonitorNetWork)
#使用线程方式执行
sTimer.start()
nTimer.start()
#等待结束
sTimer.join()
nTimer.join()
#记录结束时间
print(datetime.datetime.now())
输出结果:
2019-03-21 15:13:36.7397982019-03-21 15:13:37 bytessent=171337324, bytesrecv=11090023492019-03-21 15:13:39 cpu:1.4%, mem:93.2%2019-03-21 15:13:39.745187
可以看到,花费时间为3S,但是我们想要做的是每秒监控网络状态;如何处理。
Timer只能执行一次,所以执行完成之后需要再次添加任务,我们对代码进行修改:
from threading import Timerimport psutilimport timeimport datetimedef MonitorSystem(logfile = None): cpuper = psutil.cpu_percent() mem = psutil.virtual_memory() memper = mem.percent now = datetime.datetime.now() ts = now.strftime('%Y-%m-%d %H:%M:%S') line = f'{ts} cpu:{cpuper}%, mem:{memper}%' print(line) if logfile: logfile.write(line) #启动定时器任务,每三秒执行一次 Timer(3, MonitorSystem).start()def MonitorNetWork(logfile = None): netinfo = psutil.net_io_counters() now = datetime.datetime.now() ts = now.strftime('%Y-%m-%d %H:%M:%S') line = f'{ts} bytessent={netinfo.bytes_sent}, bytesrecv={netinfo.bytes_recv}' print(line) if logfile: logfile.write(line) #启动定时器任务,每秒执行一次 Timer(1, MonitorNetWork).start()MonitorSystem()MonitorNetWork()
执行结果:
2019-03-21 15:18:21 cpu:1.5%, mem:93.2%
2019-03-21 15:18:21 bytessent=171376522, bytesrecv=1109124678
2019-03-21 15:18:22 bytessent=171382215, bytesrecv=1109128294
2019-03-21 15:18:23 bytessent=171384278, bytesrecv=1109129702
2019-03-21 15:18:24 cpu:1.9%, mem:93.2%
2019-03-21 15:18:24 bytessent=171386341, bytesrecv=1109131110
2019-03-21 15:18:25 bytessent=171388527, bytesrecv=1109132600
2019-03-21 15:18:26 bytessent=171390590, bytesrecv=1109134008
从时间中可以看到,这两个任务可以同时进行不存在等待问题。
Timer的实质是使用线程方式去执行任务,每次执行完后会销毁,所以不必担心资源问题。
调度模块:schedule
schedule是一个第三方轻量级的任务调度模块,可以按照秒,分,小时,日期或者自定义事件执行时间;
安装方式:
pip install schedule
我们来看一个例子:
import datetimeimport scheduleimport timedef func(): now = datetime.datetime.now() ts = now.strftime('%Y-%m-%d %H:%M:%S') print('do func time :',ts)def func2(): now = datetime.datetime.now() ts = now.strftime('%Y-%m-%d %H:%M:%S') print('do func2 time:',ts)def tasklist(): #清空任务 schedule.clear() #创建一个按秒间隔执行任务 schedule.every(1).seconds.do(func) #创建一个按2秒间隔执行任务 schedule.every(2).seconds.do(func2) #执行10S for i in range(10): schedule.run_pending() time.sleep(1)tasklist()
执行结果:
do func time : 2019-03-22 08:51:38
do func2 time: 2019-03-22 08:51:39
do func time : 2019-03-22 08:51:39
do func time : 2019-03-22 08:51:40
do func2 time: 2019-03-22 08:51:41
do func time : 2019-03-22 08:51:41
do func time : 2019-03-22 08:51:42
do func2 time: 2019-03-22 08:51:43
do func time : 2019-03-22 08:51:43
do func time : 2019-03-22 08:51:44
do func2 time: 2019-03-22 08:51:45
do func time : 2019-03-22 08:51:45
do func time : 2019-03-22 08:51:46
执行过程分析:
>1>因为在jupyter下执行,所以先将schedule任务清空;>2>按时间间在schedule中隔添加任务;>3>这里按照秒间隔添加func,按照两秒间隔添加func2;>4>schedule添加任务后,需要查询任务并执行任务;>5>为了防止占用资源,每秒查询到点任务,然后顺序执行;
第5个顺序执行怎么理解,我们修改func函数,里面添加time.sleep(2)
然后只执行func工作,输出结果:
do func time : 2019-03-22 09:00:59
do func time : 2019-03-22 09:01:02
do func time : 2019-03-22 09:01:05
可以看到时间间隔为3S,为什么不是1S?
因为这个按照顺序执行,func休眠2S,循环任务查询休眠1S,所以会存在这个问题。
在我们使用这种方式执行任务需要注意这种阻塞现象。
我们看下schedule模块常用使用方法:
#schedule.every(1)创建Job, seconds.do(func)按秒间隔查询并执行schedule.every(1).seconds.do(func)#添加任务按分执行schedule.every(1).minutes.do(func)#添加任务按天执行schedule.every(1).days.do(func)#添加任务按周执行schedule.every().weeks.do(func)#添加任务每周1执行,执行时间为下周一这一时刻时间schedule.every().monday.do(func)#每周1,1点15开始执行schedule.every().monday.at("12:00").do(job)
这种方式局限性:如果工作任务回非常耗时就会影响其他任务执行。我们可以考虑使用并发机制配置这个模块使用。
任务框架APScheduler
APScheduler是Python的一个定时任务框架,用于执行周期或者定时任务,
可以基于日期、时间间隔,及类似于Linux上的定时任务crontab类型的定时任务;
该该框架不仅可以添加、删除定时任务,还可以将任务存储到数据库中,实现任务的持久化,使用起来非常方便。
安装方式:pip install apscheduler
apscheduler组件及简单说明:
1>triggers(触发器):触发器包含调度逻辑,每一个作业有它自己的触发器
2>job stores(作业存储):用来存储被调度的作业,默认的作业存储器是简单地把作业任务保存在内存中,支持存储到MongoDB,Redis数据库中
3> executors(执行器):执行器用来执行定时任务,只是将需要执行的任务放在新的线程或者线程池中运行
4>schedulers(调度器):调度器是将其它部分联系在一起,对使用者提供接口,进行任务添加,设置,删除。
来看一个简单例子:
import time
from apscheduler.schedulers.blocking import BlockingScheduler
def func():
now = datetime.datetime.now()
ts = now.strftime('%Y-%m-%d %H:%M:%S')
print('do func time :',ts)
def func2():
#耗时2S
now = datetime.datetime.now()
ts = now.strftime('%Y-%m-%d %H:%M:%S')
print('do func2 time:',ts)
time.sleep(2)
def dojob():
#创建调度器:BlockingScheduler
scheduler = BlockingScheduler()
#添加任务,时间间隔2S
scheduler.add_job(func, 'interval', seconds=2, id='test_job1')
#添加任务,时间间隔5S
scheduler.add_job(func2, 'interval', seconds=3, id='test_job2')
scheduler.start()
dojob()
输出结果:
do func time : 2019-03-22 10:32:20do func2 time: 2019-03-22 10:32:21do func time : 2019-03-22 10:32:22do func time : 2019-03-22 10:32:24do func2 time: 2019-03-22 10:32:24do func time : 2019-03-22 10:32:26
输出结果中可以看到:任务就算是有延时,也不会影响其他任务执行。
APScheduler框架提供丰富接口去实现定时任务,可以去参考官方文档去查看使用方式。
最后选择:
简单总结上面四种定时定点任务实现:
1:循环+sleep方式适合简答测试,
2:timer可以实现定时任务,但是对定点任务来说,需要检查当前时间点;
3:schedule可以定点定时执行,但是需要在循环中检测任务,而且存在阻塞;
4:APScheduler框架更加强大,可以直接在里面添加定点与定时任务;
综合考虑,决定使用APScheduler框架,实现简单,只需要直接创建任务,并将添加到调度器中即可。
vb net的定时循环_Python3-定时任务的四种实现方式相关推荐
- python定时任务_Python3实现定时任务的四种方式
最近做一个小程序开发任务,主要负责后台部分开发:根据项目需求,需要实现三个定时任务: 1>定时更新微信token,需要2小时更新一次: 2>商品定时上线: 3>定时检测后台服务是否存 ...
- java如何实现定时任务_Java定时任务的三种实现方式
前言 现代的应用程序早已不是以前的那些由简单的增删改查拼凑而成的程序了,高复杂性早已是标配,而任务的定时调度与执行也是对程序的基本要求了. 很多业务需求的实现都离不开定时任务,例如,每月一号,移动将清 ...
- 后端技术:Java定时任务的五种创建方式
Quartz表达式生成地址:http://cron.qqe2.com/ 支持生成定时任务表达式和反解析,使用Quartz表达式的定时任务如下 xxl-job springboot 的 @Schedul ...
- python循环五角星做法_python实现while循环打印星星的四种形状
在控制台连续输出五行*,每一行星号数量一次递增 * ** *** **** ***** #1.定义一个行计数器 row = 1 while row <= 5: #定义一个列计数器 col = 1 ...
- python打印星星居中_python实现while循环打印星星的四种形状
在控制台连续输出五行*,每一行星号数量一次递增 * ** *** **** ***** #1.定义一个行计数器 row = 1 while row <= 5: #定义一个列计数器 col = 1 ...
- python 使用while循环输出*组成的菱形_python实现while循环打印星星的四种形状
在控制台连续输出五行*,每一行星号数量一次递增 * ** *** **** ***** #1.定义一个行计数器 row = 1 while row <= 5: #定义一个列计数器 col = 1 ...
- java实现 定时_Java实现定时任务的几种方案重构
聊聊定时任务 定时任务,顾名思义就是,定时去完成某项任务,例如指定某个时间点去做某件事情或者是指定一定的时间间隔去做某些事情.使用定时任务就是一种对生产力的解放,如果没有定时任务的话,对于以上的需求, ...
- java定时14点30分_单机定时任务的四种基本实现方式
引言 在实际项目开发中,定时任务调度是经常会出现的一类需求. 定时任务的场景可以说非常广泛,例如: 购买某些视频网站的会员后,每天给会员送成长值,每月给会员送电影券 在保证最终一致性的场景中,利用定时 ...
- Map 集合循环、遍历的 四 种方式
前些天发现了一个巨牛的人工智能学习网站,通俗易懂,风趣幽默,忍不住分享一下给大家.点击跳转到教程. package cn.jdbc.test; import java.util.HashMap; im ...
最新文章
- 服务器负载暴涨以后...
- 数学之美系列之一:统计语言模型 (Statistical Language Models)
- 操作系统实验报告3:Linux 下 x86 汇编语言2
- spring+quartz 完整例子
- 第十八章 4string 字符串的合并
- VSTS 离线源码版本辅助工具
- Maven创建servlet项目演示(三)
- fragment中嵌套viewpager,vierpager中用fragment不显示数据
- Java进阶:SpringMVC文件上传
- 运营必备九大互联网思维
- python浪漫告白源代码_python七夕浪漫表白源码
- 【机器学习线性代数】06 解方程组:从空间的角度再引入
- 哥们别逗 了,写个脚本那真不叫运维自动化! 【转载】
- 入职快手半年工作小结
- 三国塔防魏传java_三国塔防魏传1.6详细攻略
- Qt 小例子学习26 - 画网格
- ts+v3 报错:‘Upload.vue‘ cannot be compiled under ‘--isolatedModules‘ because it is considered a global
- 膨胀的计算机仿真,烧结水分迁移数学模型及计算机仿真
- 药品注册专员前景如何?5条职业规划发展方向
- Xmanager PowerSuite7中文绿色版下载(免注册)Xmanager7、Xshell7、Xftp7和Xlpd7
热门文章
- NameError: name 'random' is not defined
- intellij Find Usage 查找符号使用快捷键alt + f7在ubuntu下无法使用的解决方法
- 南京晓庄学院大一第二学期计算机数据结构期末考试试卷及答案,南京晓庄学院数据结构题库参考答案...
- java堆栈有序无序,浅谈Java并发编程系列(四)—— 原子性、可见性与有序性
- 无惧上代信号差诟病?谷歌Pixel 7系列继续搭载三星基带芯片
- 9999元起!荣耀Magic V今日首销:首款骁龙8折叠屏旗舰
- 号称骁龙865压轴旗舰!如今降价600依然卖不动...
- 新款iPad Pro曝光:搭载A14x仿生芯片 支持5G
- 外媒:华为或将在2月24日发布麒麟820 支持5G网络
- B站举办2019年度UP主颁奖:破圈、多元、跨界成全年关键词