如何配置Celery不使用RabbitMQ作为消息代理及结果后端？

Celery支持多种消息代理和结果后端，无需绑定RabbitMQ，以下是几种实用的替代方案及配置步骤：

可选替代方案 #

• Redis：适合生产环境，性能优异，支持持久化
• SQL数据库（SQLite/PostgreSQL/MySQL）：基于SQLAlchemy，适合低负载场景或已有数据库的项目
• 文件系统：无需额外服务，仅用于测试或简单任务
• 内存存储：仅本地测试用，重启后任务和结果全部丢失

具体配置示例 #

1. 使用Redis（推荐生产/测试） #

安装依赖

pip install redis

配置方式

在Celery初始化文件（如main.py）中直接指定：

from celery import Celery

app = Celery('your_project_name',
             broker='redis://localhost:6379/0',  # 0为数据库编号，可自行修改
             backend='redis://localhost:6379/0')

或通过单独配置文件（celery_config.py）：

broker_url = 'redis://localhost:6379/0'
result_backend = 'redis://localhost:6379/0'

然后在初始化时加载配置：

app = Celery('your_project_name')
app.config_from_object('celery_config')

启动Worker

celery -A your_project_name worker --loglevel=info

注意：启动前确保Redis服务已正常运行。

2. 使用SQLite（无需额外服务，适合测试） #

安装依赖

pip install sqlalchemy

配置方式

from celery import Celery

app = Celery('your_project_name',
             broker='sqla+sqlite:///celery_broker.db',  # 本地SQLite文件作为代理
             backend='db+sqlite:///celery_results.db')  # 存储结果到SQLite

启动Worker

命令同Redis方案，Celery会自动创建对应的SQLite文件。

3. 使用文件系统（极简测试） #

配置方式

from celery import Celery

app = Celery('your_project_name',
             broker='filesystem://./celery_broker',  # 本地目录作为代理存储
             backend='file://./celery_results')      # 结果存储到本地目录

先手动创建所需目录：

mkdir -p celery_broker celery_results

启动Worker

命令同上。

4. 使用内存（仅临时测试） #

配置方式

from celery import Celery

app = Celery('your_project_name',
             broker='memory://',
             backend='cache+memory://')

此方案无需任何外部依赖，但Worker重启后所有未执行任务和结果都会丢失，仅用于快速验证代码逻辑。

关键注意事项 #

• 确保彻底替换原有RabbitMQ相关配置，避免Celery读取默认的AMQP配置
• 若通过命令行启动，可直接指定代理和后端覆盖配置：

  celery -A your_project_name worker --loglevel=info --broker=redis://localhost:6379/0 --result-backend=redis://localhost:6379/0
  

• 每种方案需安装对应依赖，否则会出现连接或初始化错误

内容的提问来源于stack exchange，提问作者MeravigliaTitti