django redis celery 和 celerybeats 的正确设置

我一直在尝试设置 django + celery + redis + celery_beats 但它给我带来了麻烦。文档非常简单，但是当我运行 django 服务器、redis、celery 和 celerybeats 时，没有打印或记录任何内容（我所有的测试任务都会记录一些内容）。

这是我的文件夹结构：

- aenima 
 - aenima
   - __init__.py
   - celery.py

 - criptoball
   - tasks.py

celery.py 看起来像这样：

from __future__ import absolute_import, unicode_literals
import os
from django.conf import settings
from celery import Celery


# set the default Django settings module for the 'celery' program.
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'aenima.settings')

app = Celery("criptoball")
app.conf.broker_url = 'redis://localhost:6379/0'

# Using a string here means the worker doesn't have to serialize
# the configuration object to child processes.
# - namespace='CELERY' means all celery-related configuration keys
#   should have a `CELERY_` prefix.
app.config_from_object('django.conf:settings', namespace='CELERY')

# Load task modules from all registered Django app configs.
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)
app.conf.timezone = 'UTC'

@app.task(bind=True)
def debug_task(self):
    print('Request: {0!r}'.format(self.request))

app.conf.beat_schedule = {
    'test-every-30-seconds': {
        'task': 'tasks.test_celery',
        'schedule': 30.0,
        'args': (16, 16)
    }, }

和tasks.py看起来像这样：

from __future__ import absolute_import, unicode_literals
from datetime import datetime, timedelta
from celery import shared_task
import logging

from django_celery_beat.models import PeriodicTask, IntervalSchedule

cada_10_seg = IntervalSchedule.objects.create(every=10, period=IntervalSchedule.SECONDS)

test_celery_periodic = PeriodicTask.objects.create(interval=cada_10_seg, name='test_celery', task='criptoball.tasks.test_celery',
expires=datetime.utcnow()+timedelta(seconds=30))

@shared_task
def test_celery(x, y):
    logger = logging.getLogger("AENIMA")
    print("EUREKA")
    logger.debug("EUREKA")

这是django_celery_beat http://django-celery-beat.readthedocs.io/en/latest/ docs

不知道我错过了什么。当我跑步时

celery -A aenimabeat -l debug --scheduler django_celery_beat.schedulers:DatabaseScheduler

celery -A aenima 工人 -l 调试

redis-cli ping 乒乓球

django runserver 和 redis 服务器，我没有打印任何内容。

设置.py

CELERY_BROKER_URL = 'redis://localhost:6379'
CELERY_RESULT_BACKEND = 'redis://localhost:6379'
CELERY_ACCEPT_CONTENT = ['application/json']
CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZER = 'json'
CELERY_TIMEZONE = TIME_ZONE
CELERY_IMPORTS = ('criptoball.tasks',)

到目前为止，还没有找到这个主题的任何权威答案。

我想解决这一切，这个错误可能只是众多错误之一。非常感谢你的帮助！

Edit:

添加了 redis 设置，以不同方式声明任务并提高了调试级别。现在错误是：

收到类型为 u'tasks.test_celery' 的未注册任务。消息 已被忽略并丢弃。

您是否记得导入包含此任务的模块？或者可能 你正在使用相对进口吗？ KeyError：u'aenima.criptoball.tasks.test_celery'

我认为 Celery 的文档很差。

EDIT 2在尝试了所有方法之后，当我将所有任务放在同一个 celery.py 文件中时，它就起作用了。 @shared_task 不起作用，必须使用 @app.task 。

我以前也遇到过这些问题。这不是你的代码。一般是环境的问题。 你应该在下面运行所有内容virtualenv，添加一个requirements.txt文件与具体软件包版本.

有一个关于的已知问题celery 4.x and django 1.x，所以你应该考虑你正在使用的包。

This http://michal.karzynski.pl/blog/2014/05/18/setting-up-an-asynchronous-task-queue-for-django-using-celery-redis/教程将详细解释如何构建virtualenv芹菜。

如果您可以告诉我您的软件包版本，我可能会尝试以不同的方式提供帮助。

Edit:

我认为这与你经营芹菜的方式有关。如果我们解决了第一个问题，请尝试使用以下命令：

celery -A aenima.celery:app beat -l debug --scheduler django_celery_beat.schedulers:DatabaseScheduler

or

celery -A aenima.aenima.celery:app beat -l debug --scheduler django_celery_beat.schedulers:DatabaseScheduler

您收到的最新错误与您的模块发现有关。 先试试吧。