来自不同日志文件中不同应用程序的芹菜任务

Question

我正在寻找FreeBSD服务器上的Celery，并且根据日志文件遇到一些问题。

我的配置：

• freebsd服务器
• 2 Django应用程序：App1和App2
• 芹菜是a耐且重新的
• 每个应用程序都有自己的芹菜任务

我的芹菜配置文件：

我有/etc/etc/default/celeryd_app1 ：

# Names of nodes to start
CELERYD_NODES="worker"
# Absolute or relative path to the 'celery' command:
CELERY_BIN="/usr/local/www/app1/venv/bin/celery"
# App instance to use
CELERY_APP="main"
# Where to chdir at start.
CELERYD_CHDIR="/usr/local/www/app1/src/"
# Extra command-line arguments to the worker
CELERYD_OPTS="--time-limit=300 --concurrency=8"
# Set logging level to DEBUG
#CELERYD_LOG_LEVEL="DEBUG"
# %n will be replaced with the first part of the nodename.
CELERYD_LOG_FILE="/var/log/celery/app1/%n%I.log"
CELERYD_PID_FILE="/var/run/celery/app1/%n.pid"
# Workers should run as an unprivileged user.
CELERYD_USER="celery"
CELERYD_GROUP="celery"
# If enabled pid and log directories will be created if missing,
# and owned by the userid/group configured.
CELERY_CREATE_DIRS=1

我有 celeryd_app2

的文件完全相同

django设置文件带有芹菜设置：

CELERY_BROKER_URL = 'redis://localhost:6379'
CELERY_ACCEPT_CONTENT = ['application/json']
CELERY_RESULT_BACKEND = 'redis://localhost:6379'
CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZER = 'json'
CELERY_IGNORE_RESULT = False
CELERY_TASK_TRACK_STARTED = True
# Add a one-minute timeout to all Celery tasks.
CELERYD_TASK_SOFT_TIME_LIMIT = 60

两个设置都有相同的redis端口。

我的问题：

当我执行app1的芹菜任务时，我在App2日志文件中找到具有这样的问题的日志：

Received unregistered task of type 'app1.task.my_task_for_app1'
...
KeyError: 'app1.task.my_task_for_app1'

我的芹菜配置文件中有一个问题吗？我必须设置不同的redis端口？如果是，我该怎么做？

非常感谢

Answer 1

我想问题在于您在两个应用程序中都使用相同的redis数据库：

CELERY_BROKER_URL = 'redis://localhost:6379'

探讨将Redis用作经纪人的指南。只需更改每个应用程序的数据库，例如

CELERY_BROKER_URL = 'redis://localhost:6379/0'

和

CELERY_BROKER_URL = 'redis://localhost:6379/1'