Django Celery 4启动Worker报错：ValueError: invalid literal for int() with base 10

我之前也碰到过类似的坑，结合Celery搭配AWS SQS的配置经验，给你几个针对性的排查方向：

1. 先确认SQS依赖是否安装到位 #

Celery默认不带SQS的支持组件，必须单独安装对应的依赖包，执行这个命令就行：

pip install celery[sqs]

这个命令会自动安装boto3、kombu-sqs这些SQS适配所需的库，比单独装更稳妥。

2. 检查SQS代理URL的格式是否正确 #

AWS SQS的Broker URL格式有严格要求，最容易踩坑的几个点：

• 带密钥的正确格式：sqs://AWS_ACCESS_KEY_ID:AWS_SECRET_ACCESS_KEY@，注意末尾的@绝对不能省略！
• 如果你的服务用了IAM角色（比如EC2实例、EKS Pod），不需要硬编码密钥，可以直接写：sqs://
• 区域信息不要写在URL里，要单独配置在broker_transport_options中，比如：

# celery.py中的配置示例
app.conf.broker_transport_options = {
    'region': 'us-east-1',  # 替换成你的AWS区域
    'visibility_timeout': 3600,  # 消息可见性超时，按需调整
}

3. 验证AWS权限是否足够 #

你的AWS账号（或IAM角色）必须拥有SQS的核心操作权限，至少要包含：

• sqs:CreateQueue
• sqs:ReceiveMessage
• sqs:SendMessage
• sqs:DeleteMessage
• sqs:GetQueueAttributes
  权限不足会触发底层的API错误，最终可能包装成ValueError抛出。

4. 检查版本兼容性 #

你用的是Python3.6，要注意：Celery 5.x及以上版本已经不再支持Python3.6了！如果你装了Celery5+，必然会出现兼容性问题。建议降级到支持Python3.6的Celery版本：

pip install celery==4.4.7

补充：完整的celery.py配置示例 #

给你一个经过验证的配置模板，避免遗漏关键项：

from celery import Celery

# 初始化Celery实例
app = Celery('your_project_name')

# Broker配置（SQS）
app.conf.broker_url = 'sqs://AWS_ACCESS_KEY:AWS_SECRET@'
app.conf.broker_transport_options = {
    'region': 'us-west-2',
    'visibility_timeout': 3600,
    'queue_name_prefix': 'proj-'  # 可选，给队列加前缀方便管理
}

# 结果后端配置（按需选择，比如用Django数据库）
app.conf.result_backend = 'django-db'
app.conf.task_serializer = 'json'

如果按照上面的步骤排查后还是报错，建议把完整的ValueError提示信息贴出来（你现在的报错内容截断了），比如具体的错误描述，这样能更精准定位问题。

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