Django Celery 4.0.0: 没有找到该传输：django

在本文中，我们将介绍Django Celery 4.0.0中出现的一个常见错误：“No such transport: django”。我们将了解这个错误的原因以及如何解决它。

问题背景

在Django Celery 4.0.0版本中，许多用户在尝试使用Celery消息队列时都遇到了一个常见的错误：“No such transport: django”。这个错误表示Celery无法找到名为“django”的传输。

错误原因

这个错误的原因是因为Django Celery 4.0.0不再默认支持使用Django作为消息队列传输。在之前的版本中，Celery默认使用Django数据库作为传输，但在新的版本中，这种方式被弃用了。因此，当我们在Django Celery 4.0.0中使用默认配置时，会出现“No such transport: django”错误。

解决方法

要解决这个错误，我们需要进行以下步骤：

步骤1：安装额外的传输插件

为了使用Django作为传输，我们需要安装额外的传输插件。在Celery的官方文档中提供了多种可选的传输插件，可以根据自己的需求选择合适的插件。以下是一些常用的传输插件：

redis：通过Redis作为消息队列传输。
RabbitMQ：通过RabbitMQ作为消息队列传输。
SQS：通过Amazon Simple Queue Service作为消息队列传输。

根据你选择的传输插件，使用pip命令安装相应的插件。例如，如果我们选择使用Redis作为传输，我们可以运行以下命令来安装相关的插件：

pip install django-celery-results[redis]

步骤2：配置Celery

安装所需的传输插件后，我们需要在Django项目的配置文件中进行相应的配置。打开settings.py文件，并添加以下配置：

# 使用Redis作为传输，配置如下：
CELERY_BROKER_URL = 'redis://localhost:6379/0'
CELERY_RESULT_BACKEND = 'redis://localhost:6379/0'

# 使用RabbitMQ作为传输，配置如下：
CELERY_BROKER_URL = 'amqp://localhost'
CELERY_RESULT_BACKEND = 'amqp://localhost'

请根据你选择的传输插件进行相应的配置。

步骤3：启动Celery

配置完毕后，我们可以启动Celery来处理异步任务。在终端中进入Django项目的根目录，并运行以下命令：

celery -A your_project_name worker --loglevel=info

其中your_project_name是你的Django项目的名称。

如果一切顺利，你将看到Celery成功启动，并且不再遇到“No such transport: django”错误。

示例

为了更好地理解解决方法，我们以一个简单的示例来展示如何在Django Celery 4.0.0中使用Redis作为传输。

首先，安装Redis和所需的插件：

pip install redis
pip install django-celery-results[redis]

然后，在Django项目的settings.py中添加以下配置：

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

接下来，我们创建一个异步任务，在tasks.py文件中添加以下代码：

from celery import shared_task

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

最后，我们在视图中调用异步任务：

from django.shortcuts import render
from .tasks import add

def home(request):
    result = add.delay(4, 5)
    context = {'result': result.get()}
    return render(request, 'home.html', context)

运行Celery：

celery -A your_project_name worker --loglevel=info

启动Django服务并访问网页，你将看到结果为9，表示异步任务成功执行。

总结

在本文中，我们解释了Django Celery 4.0.0中出现的错误：“No such transport: django”。我们了解到这是由于新版本中不再默认支持使用Django作为消息队列传输所致。为了解决这个错误，我们需要安装额外的传输插件，并在配置文件中进行相应的配置。通过示例演示了如何在Django Celery 4.0.0中使用Redis作为传输。希望本文对你理解和解决这个问题有所帮助。