定时任务在开发中应用广泛，几乎所有开发人员都会接触到。实现定时任务的方法有很多，其中celery的定时任务功能强大且使用简便，只需安装celery即可。以下是使用celery实现定时任务的详细步骤。
一. 搭建Celery定时任务架构
在项目中合适的位置新建一个定时任务目录
celery_crontab，在该目录下创建
config.py、
main.py和
tasks.py三个文件，分别用于编写配置代码、定时任务实现代码和任务函数代码。
# 目录结构
- celery_crontab
- config.py
- main.py
- tasks.py
二. 编写代码实现定时任务
- 在
config.py
中编写配置代码
from celery import Celery
<h1>broker，使用RabbitMQ</h1><p>app = Celery('celery_crontab', broker='amqp://guest@localhost//')</p><h1>或使用Redis</h1><h1>app = Celery('demo', broker='redis://127.0.0.1:6379/15')- 在
tasks.py
中编写任务函数代码
from config import app</h1><p>@app.task
def crontab_func1():
print('在此编写任务要实现的代码')</p><p>@app.task
def crontab_func2():
print('在此调用实现了定时任务功能的函数或方法')- 在
main.py
中调用任务，并实现定时任务功能
from celery.schedules import crontab
from tasks import *</p><h1>设置定时任务</h1><p>app.conf.beat_schedule = {</p><h1>设置定时任务的参数，key可以自定义，见名知义</h1><pre class="brush:php;toolbar:false;"># value为定时任务的相关参数的字典
'contab_func1-every-1-minute': {
# 指定要执行的任务函数
'task': 'tasks.crontab_func1',
# 设置定时启动的频率，每分钟执行一次任务函数
'schedule': crontab(minute='*/1'),
# 传入任务函数的参数，可以是一个列表或元组
# 如果函数没参数则为空列表或空元组
'args': []
},
'contab_func2-every-day': {
'task': 'tasks.crontab_func2',
# 每周一至周五早上8点执行任务函数
'schedule': crontab(minute=0, hour=8, day_of_week=[1, 2, 3, 4, 5]),
'args': []
},}
实现定时任务的另一种方式
@app.on_after_configure.connect def setup_periodic_tasks(sender, **kwargs):
sender.add_periodic_task(间隔时间秒, 任务名.s(参数), name='自定义任务名')
sender.add_periodic_task(10.0, crontab_func1.s(), name='crontab_func1 every 10')
sender.add_periodic_task(
# 每分钟执行一次
crontab(minute='*/1'),
# .s()内传入任务函数需要的参数
crontab_func2.s()
)</code>在Celery文档中列举了更多任务频率的设置方式，可以直接阅读文档Celery documentation：
http://docs.celeryproject.org/en/latest/userguide/periodic-tasks.html
生成可在 deepbi 沙箱 iframe 内运行或作为独立文件运行的交互式 HTML 页面，使用 `window.deepbi` JS SDK 实现数据查询、空间管理、文件浏览及用户操作。当用户提出以下需求时启用该能力： - 创建 KPI 仪表盘、数据表格、文件浏览器、成员列表、管理页面； - 明确要求“转成 dhtml”、“转译成 HTML”、“把 XX 页面转成……”、“控制台页面”、“管理后台”、“DeepBI 页面迁移”； - 提及位于 `apps/console/src/featur
也可以按住Ctrl左键点击代码中的crontab，进入源码查看__doc__（文档注释）内容，里面也列举了很多任务频率的设置方法。
三. 启动定时任务
启动定时任务应在main.py的位置，所以最好到main.py所在目录下执行命令，在其他位置启动时要指定main的路径。
<code class="javascript">'''使用multi方式启动定时任务，celery会自动生成任务子节点和自动创建子进程
work为执行任务的进程名字 -A main 指定定时任务的启动函数main -l info 指定日志等级为info -B 将celery定时任务设置为后台守护进程，不占用终端 --logfile=celerylog.log 指定日志保存的文件名，也可指定路径加文件名''' celery multi start work -A main -l info -B --logfile=celerylog.log
停止定时任务时，将start换成stop
celery multi stop work -A main -l info -B --logfile=celerylog.log
重启定时任务，将start换成restart
celery multi restart work -A main -l info -B --logfile=celerylog.log
在Celery的使用场景中，无论是实现异步任务还是定时任务，基本都会依赖命令来启动和停止任务，因此Celery的命令非常多。了解更多Celery的命令可以到文档中查看。Celery documentation：
https://www.php.cn/link/f82eedc57df33f85b6938f71ed72032f
也可以在终端输入
celery -h查看帮助信息。
Windows Bug：
RuntimeError: This platform does not support detach。在
site-packages\celery\platforms.py中尝试导入模块“resource”时失败，这个模块不支持Windows，因此定时任务应该部署在Linux系统上。
