为什么我的 celery 任务没有运行?

ama*_*sil 3 django celery django-celery

我正在遵循本指南:http : //docs.celeryproject.org/en/latest/django/first-steps-with-django.html

我的 proj.celery 文件:

from __future__ import absolute_import, unicode_literals
import os
from celery import Celery
from celery.schedules import crontab

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'hc.settings')

app = Celery('hc')

app.config_from_object('django.conf:settings', namespace='CELERY')
app.autodiscover_tasks()


@app.task
def debug_task(a):
    print a
app.conf.beat_schedule = {
    # Executes every Monday morning at 7:30 a.m.
    'debug-every-minute': {
        'task': 'tasks.debug_task',
        'schedule': crontab(),
        'args': ("BLa BLA BlA", ),
    },
}
Run Code Online (Sandbox Code Playgroud)

另外,我已将定期任务添加到 /admin/django_celery_beat/

我知道app.conf.beat_schedule在 admin 中同时使用和 period_task是没有意义的,但我没有看到预期的条目

Starting development server at http://127.0.0.1:8000/
Quit the server with CONTROL-C.
Run Code Online (Sandbox Code Playgroud)

(我希望 Bla bla 会写在那个下面)我错在哪里?

itz*_*nTV 7

运行芹菜

celery -A hc worker -B -l info
Run Code Online (Sandbox Code Playgroud)

  • 代表“celery --app hc worker --beat --loglevel=INFO” (2认同)