Celery无法使用SQLite作为后端的问题排查求助

让我们一步步拆解你的问题，搞定这两个配置报错：

1. 第一次错误的核心原因 #

你最初的配置里犯了两个小错：

• 配置项名称错误：你用了CELERY_BROKER_BACKEND = "sqlakombu.transport.Transport"，但在Celery 4.x中，指定Broker传输类的正确配置项是CELERY_BROKER_TRANSPORT（或者小写的broker_transport，Celery 4.x兼容两种写法），CELERY_BROKER_BACKEND并不是用来定义传输类的。
• URL格式不匹配：CELERY_BROKER_URL用了db+sqlite:///results.sqlite，而sqlakombu传输层对应的URL前缀是sqlalchemy，不是db，所以Celery找不到对应的传输模块。

2. 第二次错误的核心原因 #

你改成sqla+sqlite:///后，Celery会尝试去加载名为sqla的传输模块，但这个模块根本不存在，自然就抛出了ImportError: No module named sqla。

正确的配置方案 #

结合你的包版本（Celery 4.1.1 + kombu-sqlalchemy 1.1.0），正确的配置应该是这样的：

# 指定Broker使用sqlakombu传输类
CELERY_BROKER_TRANSPORT = "sqlakombu.transport.Transport"
# Broker URL：使用sqlalchemy前缀，对应sqlite相对路径
CELERY_BROKER_URL = "sqlalchemy:///results.sqlite"
# Result Backend和Cache Backend使用sqlite的标准格式
CELERY_RESULT_BACKEND = "db+sqlite:///results.sqlite"
CELERY_CACHE_BACKEND = "db+sqlite:///results.sqlite"

配置细节说明：

• CELERY_BROKER_TRANSPORT：明确告诉Celery用sqlakombu的传输类来和SQLAlchemy数据库交互。
• CELERY_BROKER_URL：sqlakombu要求必须用sqlalchemy://作为URL前缀，如果你用绝对路径的话，写法是sqlalchemy:////absolute/path/results.sqlite（四个斜杠）。
• CELERY_RESULT_BACKEND和CELERY_CACHE_BACKEND：这两个配置用db+sqlite:///是完全正确的，因为Celery的结果后端原生支持这个格式连接SQLite。

验证步骤 #

1. 先确认依赖包都安装正确：

pip install SQLAlchemy==1.2.8 kombu==4.2.0 kombu-sqlalchemy==1.1.0 celery==4.1.1

2. 替换配置后，重新启动Celery worker：

celery worker -A proj --loglevel=info

这样应该就能正常启动，不会再出现传输类找不到的错误了。

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