redis - 使用 Celery + Redis 时出现巨大延迟

Question

我正在测试 Django + Celery， Hello World 示例。使用 RabbitMQ celery 工作正常，但是当我切换到 Redis 代理/结果时，我得到以下信息:

%timeit add.delay(1,2).get()
1 loops, best of 3: 503 ms per loop

settings.py

CELERY_RESULT_BACKEND = "redis"
BROKER_URL = 'redis://localhost:6379'

tasks.py

@task()
def add(x, y):
    return x + y

上面的测试有没有问题？

Answer 1

我发现解决方案是源代码: http://docs.celeryproject.org/en/latest/_modules/celery/result.html#AsyncResult.get

interval – Time to wait (in seconds) before retrying to retrieve the result. Note that this does not have any effect when using the amqp result store backend, as it does not use polling.

默认为 0.5 秒。您可以手动更改它，但不推荐运行任务的方式:

%timeit add.delay(1,2).get(interval=0.001)
100 loops, best of 3: 3.92 ms per loop