简介

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添加定时任务分为如下几步

1. 引入相关的对象
2. 使用add_job注册一个定时任务，需要提供trigger，name和notice是可选的，当你的任务需要异常提醒的时候要提供notice，建议提供name，这样有利于阅读
3. 编写定时函数内容
4. 运行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:123456@127.0.0.1:27017
MONGO_URI = ''

# 如果定时任务存在某个模块下，提供模块的名字
WORK_MODULE = 'work'

# 钉钉的Token，如果选择使用钉钉提醒
DING_TOKEN = ''

# 邮件设置
EMAIL_USER = ''  # 账户
EMAIL_PWD = ''  # IMAP密码
EMAIL_HOST = ''
EMAIL_TO_USER = ''

todo

目前这个项目处于早期的版本，不足之处还有很多，后续要陆续优化
后续还打算提供一个简单的前端页面来展示定时任务运行记录

版本更新

• 2022-04-18更新0.0.2
  • 支持基于内存管理Job和Task
  • 完善backend部分单元测试