django - 我在使用 Celery、Redis 和 Django 时遇到问题

Question

我在使用 Celery、Redis 和 Django 时遇到问题。

我正在尝试使用它们来创建一个简单的任务。

但是，任务执行不久就出现了错误。

我将在下面详细说明部分代码，以便更好地理解。感谢您的关注。

CELERY_BROKER_URL = 'redis://:password@REDIS:6379/0'
CELERY_RESULT_BACKEND = 'redis://REDIS:6379/0'
CELERY_ACCEPT_CONTENT = ['application/json']
CELERY_RESULT_SERIALIZER = 'json'
CELERY_TASK_SERIALIZER = 'json'
CELERY_TIMEZONE = 'America/Recife'
CELERY_BEAT_SCHEDULE = {
    'task-send': {
        'task': 'app.tasks.task_send_email',
        'schedule': crontab(hour=5, minute=44)
    }
}

控制台 celery

[config]
app:         sistema:0x7fa254a5d6f4
transport:   redis://:**@redis:6379/0
results:     redis://redis:6379/0
concurrency: 1 (prefork)
task events: OFF (enable -E to monitor tasks in this worker)

[queues]
exchange=celery(direct) key=celery

[tasks]
app.tasks.task_send_email

INFO/MainProcess] Connected to redis://:**@redis:6379/0
INFO/MainProcess] mingle: searching for neighbors
INFO/MainProcess] mingle: all alone

执行任务后出现错误

RuntimeWarning: Exception raised outside body: ResponseError('NOAUTH Authentication required.',):

任务未完成。

Answer 1

考虑到您的结果后端 URL 没有身份验证 token ，并且您使用显然期望它的同一台服务器，我认为发生的情况如下:您可以成功运行任务(因为后端 URL 是正确的)，但是一旦任务运行，Celery 尝试存储结果(在结果后端)，但是由于结果后端 URL 无效(redis://redis:6379/0，应该类似于代理，即 redis://:**@redis:6379/1 - 使用不同的数据库名称)Celery 抛出异常，因为它无法连接到 Redis(需要 NOAUTH 身份验证 来自 Redis 服务器)。

假设您的 Redis 服务器是 redis.local，您的 Redis 身份验证 token 是 my53cr3tt0ken。你的 Celery 配置应该有这两个:

broker_url = "redis://:my53cr3tt0ken@redis.local:6379/0"
celery_result_backend = "redis://:my53cr3tt0ken@redis.local:6379/1"

请注意，我为代理和结果后端使用不同的数据库 - 我建议您也这样做。

如果您的 Redis 加密通信，那么您应该使用 rediss://...。