设置简单任务的麻烦

Question

我正在尝试使用 django 和 celery.

设置一个简单的任务（每 5 秒打印 "foo"）

假设我有以下项目：

.
├── manage.py
└── proj
    ├── __init__.py
    ├── settings.py
    ├── tasks.py
    ├── urls.py
    └── wsgi.py

与 tasks.py :

from celery import Celery
import os

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

from django.conf import settings

app = Celery('tasks', broker='django://127.0.0.1:8000//')

app.config_from_object('django.conf:settings')
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)

@app.task
def test():
    print("FOO")

和settings.py：

INSTALLED_APPS = [
    'django.contrib.admin',
    'django.contrib.auth',
    'django.contrib.contenttypes',
    'django.contrib.sessions',
    'django.contrib.messages',
    'django.contrib.staticfiles',
    'celery',
    'kombu.transport.django',
]

[...]

# Celery :                                                                                                 

CELERYBEAT_SCHEDULE = {
    'test-celery': {
    'task' : 'proj.tasks.test',
        'schedule' : timedelta(seconds=5)
    },
}

CELERY_TIMEZONE = 'Europe/Paris'

和proj/__init__.py:

from .tasks import app as celery_app

我迁移，使用 celery -A proj.tasks worker --loglevel=info 启动并启动 celery，我只有两个关于此版本 (3.1.23) 和关于 settings.DEBUG 是 True。但芹菜似乎有效。我还使用 manage.py.

启动我的开发服务器

那为什么不是我的任务 (test()) 运行?

Answer 1

您需要运行 Celery Beat。例如像这样：

celery -A proj worker -l info -B

设置简单任务的麻烦

Troubles to set up a simple task

django

celery

python-3.x

django-1.9