Django视图中Celery任务阻塞无法执行（AWS SQS作为Broker）求助

我来帮你一步步排查这个Celery任务卡住的问题，这种情况在搭配AWS SQS作为Broker时确实容易踩几个坑，咱们从几个关键方向入手：

你提到Celery命令有输出，那先重点看启动日志里的Broker连接信息：

• 有没有看到类似Connected to sqs://...的成功提示？如果日志里出现认证失败、无法找到队列或者超时的报错，那核心问题就在连接上。
• 检查settings.py里的Broker URL格式是否正确：
  SQS的标准格式是sqs://AWS_ACCESS_KEY_ID:AWS_SECRET_ACCESS_KEY@，如果用环境变量传递密钥，也可以简化为sqs://，但要确保启动Celery的终端能读取到AWS_ACCESS_KEY_ID和AWS_SECRET_ACCESS_KEY这两个环境变量——比如你在Django服务器的终端设置了，但Celery的终端没加载到，就会导致权限失效。
• 别忘了指定SQS区域！如果你的队列在us-west-2这类非默认区域，必须在配置里加上：

  # settings.py
  CELERY_BROKER_URL = "sqs://@us-west-2/"
  CELERY_BROKER_TRANSPORT_OPTIONS = {
      "region": "us-west-2",
      "visibility_timeout": 3600,
  }
  

• 默认情况下Celery会监听名为celery的队列，如果你的任务指定了自定义队列（比如在tasks.py里用@app.task(queue="my_queue")），那启动Worker时必须明确指定队列：

  celery -A your_project_name worker -Q celery,my_queue -l info
  

• 当你调用my_task.delay()时，去看Worker的日志，有没有出现Received task: your_app.tasks.my_task[xxxxxx]的记录？如果没有，说明任务要么没发到SQS，要么Worker没监听对应队列。

你说代码卡在my_task.delay()这一行，这说明Celery在往SQS发任务的环节就卡住了，不是任务执行的问题。可以做个快速测试：

• 打开Django shell，手动调用任务：

  from your_app.tasks import my_task
  my_task.delay()
  

  如果这里也卡住，那100%是Broker连接的问题，和视图逻辑无关。此时可以检查SQS队列的状态（是否存在、是否被禁用），或者AWS网络是否有访问限制（比如本地网络能不能连AWS SQS？可以试试用aws sqs list-queues命令测试）。

虽然你说IAM用户有SQS完全访问权限，但要注意：

• 这个IAM用户是否和SQS队列在同一个AWS账户下？跨账户访问需要额外的队列权限配置。
• 权限策略是否包含了所有必要的动作？比如sqs:SendMessage、sqs:ReceiveMessage、sqs:DeleteMessage这些核心动作，完全访问权限应该包含，但可以去IAM控制台再确认一下策略内容。

你提到了版本信息（虽然没写具体），但Celery和依赖库的版本不兼容也可能导致连接问题：

• Celery 5.x 需要boto3 >= 1.10.0，旧版本的boto3可能无法正确处理SQS的API调用。
• 可以用下面的命令查看版本：

  pip list | grep -E 'celery|boto3|django'
  

  如果版本差距较大，尝试升级到兼容的稳定版本。

如果你的settings.py里DEBUG=True，可以临时改成False再测试——虽然一般不会导致任务卡住，但DEBUG模式下Django的一些调试机制可能会干扰异步任务的发送流程。

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