Python3.6 Schedule模块定时任务
本文使用Python的Schedule模块、Python访问数据库的框架SQLAIchemy 实现了一个:周期性读取mysql 数据的小示例。
一,编程环境
PyCharm2016,Anaconda3 Python3.6
需要安装schedule模块,该模块网址:https://pypi.python.org/pypi/schedule
打开Anaconda Prompt,输入:conda install schedule 提示:Package Not Found Error
于是,使用 pip 安装。由于Anaconda3 中已经自带了pip,如下图:
于是 cmd 命令行切换到 scripts 目录,执行 pip.exe install schedule 安装成功。这样就可以在PyCharm里面 import schedule 了
二, 在每天某个指定的时间点上,从数据库中查找数据然后写入 csv 文件
①使用 sqlalchemy 模块来建立数据库连接,关于windows 下 python3.6 for mysql 驱动安装,可参考:windows10 下使用Pycharm2016 基于Anaconda3 Python3.6 安装Mysql驱动总结
②使用schedule 模块来执行周期性任务。关于该模块的用法,可参考官网示例。
③使用csv模块将查询到的记录写入文件
整个完整代码如下:
import schedule
import codecs
import csv
import time
from sqlalchemy import create_engine def get_conn():
engine = create_engine("mysql+pymysql://root:password@localhost:3306/test?charset=utf8mb4")
conn = engine.connect()
return conn def query():
sql = "select * from user limit 10"
conn = get_conn()
return conn.execute(sql) def read_mysql_to_csv(filename):
with codecs.open(filename=filename, mode='w') as f:
write = csv.writer(f, dialect='excel') results = query()
for result in results:
write.writerow(result) schedule.every().day.at("17:49").do(read_mysql_to_csv, "test")
while True:
schedule.run_pending()
time.sleep(10)
三,总结
schedule 模块可以非常方便地实现:周期性地在每天的某个时间点上执行任务。其官方示例如下:
import schedule
import time def job():
print("I'm working...") schedule.every(10).minutes.do(job)
schedule.every().hour.do(job)
schedule.every().day.at("10:30").do(job)
schedule.every().monday.do(job)
schedule.every().wednesday.at("13:15").do(job) while True:
schedule.run_pending()
time.sleep(1)
另外,关于 Sqlalchemy 的中文资料感觉好少,而官网的示例看起来又比较困难。推荐一本英文版书籍:《essential sqlalchemy》。这本书讲了很多可直接运行的示例程序,比官网上的示例要更容易理解。
参考链接:https://github.com/dbader/schedule
原文:http://www.cnblogs.com/hapjin/p/7805820.html
最新文章
- c#进阶之神奇的CSharp
- URLEncode与URLDecode总结与实现
- Code First 约定
- Oracle存储过程学习备忘
- C++调用python
- Nginx之负载均衡
- sql2008R2sp1局域网镜像环境实操(无见证服务器)
- 科普 TLS 1.3—新特性与开启方式
- 推荐一款接口 API 设计神器!
- 大数开方 ACM-ICPC 2018 焦作赛区网络预赛 J. Participate in E-sports
- #254 Check for Palindromes
- mysql主从复制总结
- Centos下新建用户及修改用户目录
- winform中的TreeView的数据绑定
- 在sublime text3中安装sass编译scss文件
- mysql 合理创建索引
- Flask初级(四)flash在模板中使用静态文件
- L148
- [HDU6326]Monster Hunter(贪心)
- caffe2安装教程
热门文章
- Hdoj 1087.Super Jumping! Jumping! Jumping!
- LaTeX教程与下载
- centos7修改默认网卡名称
- DNA Consensus String
- Codeforces Round #516 (Div. 2)D. Labyrinth(BFS)
- uWSGI+Nginx安装、配置
- 1145. Hashing - Average Search Time
- 【洛谷P2568】GCD
- Linux批量修改(删除)文件名某些字符(rename命令)
- msvcp100d.dll文件丢失,解决找不到msvcp100d.dll的问题