celery_crontab

config.py

main.py

tasks.py

# 目录结构
- celery_crontab
    - config.py
    - main.py
    - tasks.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')

from config import app</h1><p>@app.task
def crontab_func1():
print('在此编写任务要实现的代码')</p><p>@app.task
def crontab_func2():
print('在此调用实现了定时任务功能的函数或方法')

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;"><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': []
},

<pre class="brush:php;toolbar:false;">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></pre><p>在Celery文档中列举了更多任务频率的设置方式，可以直接阅读文档Celery documentation：</p><p><a href="http://docs.celeryproject.org/en/latest/userguide/periodic-tasks.html">http://docs.celeryproject.org/en/latest/userguide/periodic-tasks.html</a></p><p>也可以按住Ctrl左键点击代码中的<code>crontab</code>，进入源码查看<code>__doc__</code>（文档注释）内容，里面也列举了很多任务频率的设置方法。</p><p><img src="/uploads/20250430/174597183968116a7f42b2a.jpg" alt="Celery实现定时任务crontab" /></p><p><strong>三. 启动定时任务</strong></p><p>启动定时任务应在<code>main.py</code>的位置，所以最好到<code>main.py</code>所在目录下执行命令，在其他位置启动时要指定<code>main</code>的路径。</p><pre><code class="javascript">'''使用multi方式启动定时任务，celery会自动生成任务子节点和自动创建子进程

celery -h

RuntimeError: This platform does not support detach

site-packages\celery\platforms.py