plana是一个非常简单的定时任务框架，内置了异常提醒和任务记录功能
现阶段使用需要配置一个MongoDB，因为还没有前端的展示功能，待后续开发，两天前萌生了一个想法，想要做一个定时任务框架，现在我的定时任务都基于linux的Crontab来管理，
许多小脚本存放于服务器的各个地方，想使用一种统一的方式来管理他们。开源的方案也有，看了一些任务调度框架，但是它们部署都挺麻烦，而且不一定适用，于是就有了这个项目，它是基于APScheduler开发的。
pip install git+https://github.com/yudeqang/plana.git
from plana.core import add_job, start, NoticeException
from plana.core.notice import EmailNotice, DingDingNotice
from plana.core import IntervalTrigger, CronTrigger
# 使用EMAIL提醒需要提供settings.py配置文件或者实例化的时候传入参数
notice = EmailNotice()
# 还可选择使用钉钉提醒, 需要传入一个钉钉的token或者配置文件中提供
# notice = DingDingNotice(token)
# crontab风格的定时器
# trigger = CronTrigger.from_crontab('0 12 * * *')
# 间隔时间运行的定时器
trigger = IntervalTrigger(seconds=3)
@add_job(trigger, name='你好啊', notice=notice)
def say_hello():
"""Interval 示例"""
try:
print("hello world")
except:
raise NoticeException('定时任务异常')
start()以上几行代码做了如下的事情：
每三秒运行一次say_hello函数
异常时发送邮件提醒
记录每次运行say_hello的信息
plana中有几个基本的对象：
job 指的是一个定时任务
task 一个定时任务每运行一次就是一个task
trigger 定时器，有两种选择，间隔时间，或者linux cron 格式的定时器，示例中使用的是间隔时间，每隔3秒运行一次
notice 提醒器，内置了两种，钉钉和邮件提醒
使用plana添加定时任务分为如下几步
- 引入相关的对象
- 使用add_job注册一个定时任务，需要提供trigger，name和notice是可选的，当你的任务需要异常提醒的时候要提供notice，建议提供name，这样有利于阅读
- 编写定时函数内容
- 运行start方法
要触发提醒，需要抛出一个NoticeException
from plana.core.Exceptions import NoticeException
def test():
raise NoticeException('定时任务异常啦')
可以在项目下新建settings.py 来更改配置。
import os
# 配置日志
LOG_NAME = os.path.basename(os.getcwd())
LOG_PATH = "log/%s.log" % LOG_NAME # log存储路径
LOG_LEVEL = "DEBUG"
LOG_COLOR = True # 是否带有颜色
LOG_IS_WRITE_TO_CONSOLE = True # 是否打印到控制台
LOG_IS_WRITE_TO_FILE = False # 日志是否写入到文件，生产环境部署时建议开启
LOG_MODE = "w" # 写文件的模式 w or a
LOG_MAX_BYTES = 10 * 1024 * 1024 # 每个日志文件的最大字节数
LOG_BACKUP_COUNT = 20 # 日志文件保留数量
LOG_ENCODING = "utf8" # 日志文件编码
# 是否详细的打印异常
PRINT_EXCEPTION_DETAILS = True
# 设置不带颜色的日志格式
LOG_FORMAT = "%(threadName)s|%(asctime)s|%(filename)s|%(funcName)s|line:%(lineno)d|%(levelname)s| %(message)s"
# 设置带有颜色的日志格式
os.environ["LOGURU_FORMAT"] = (
"<green>{time:YYYY-MM-DD HH:mm:ss.SSS}</green> | "
"<level>{level: <8}</level> | "
"<cyan>{name}</cyan>:<cyan>{function}</cyan>:<cyan>line:{line}</cyan> | <level>{message}</level>"
)
OTHERS_LOG_LEVAL = "ERROR" # 第三方库的log等级
# Mongo连接，如果数据job和task需要存在mongo中请提供这个选项
# mongodb://root:[email protected]:27017
MONGO_URI = ''
# 如果定时任务存在某个模块下，提供模块的名字
WORK_MODULE = 'work'
# 钉钉的Token，如果选择使用钉钉提醒
DING_TOKEN = ''
# 邮件设置
EMAIL_USER = '' # 账户
EMAIL_PWD = '' # IMAP密码
EMAIL_HOST = ''
EMAIL_TO_USER = ''目前这个项目处于早期的版本，不足之处还有很多，后续要陆续优化
后续还打算提供一个简单的前端页面来展示定时任务运行记录
- 2022-04-18更新0.0.2
- 支持基于内存管理Job和Task
- 完善backend部分单元测试
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent