amazon-web-services - celery 与亚马逊 SQS

Question

我想使用Amazon SQS作为Celery支持的经纪人。 Kombu 的 SQS 传输实现，Celery 依赖于此。但是没有足够的文档来使用它，所以我找不到如何在 Celery 上配置 SQS。有人在 Celery 上成功配置了 SQS 吗？

Answer 1

我多次遇到这个问题，但仍然不完全确定如何设置 Celery 来与 SQS 一起使用。事实证明，使用最新版本的 Kombu 和 Celery 非常容易。作为另一个答案中提到的 BROKER_URL 语法的替代方案，您可以简单地设置传输、选项、用户和密码，如下所示:

BROKER_TRANSPORT = 'sqs'
BROKER_TRANSPORT_OPTIONS = {
    'region': 'us-east-1',
}
BROKER_USER = AWS_ACCESS_KEY_ID
BROKER_PASSWORD = AWS_SECRET_ACCESS_KEY

这解决了据称的 URL 解析器问题，该问题不允许在 API key 中使用正斜杠，这在 AWS 中似乎是相当常见的情况。由于似乎还没有关于该主题的大量信息，因此我还在这里写了一篇关于该主题的简短博客文章:

http://www.caktusgroup.com/blog/2011/12/19/using-django-and-celery-amazon-sqs/