如何在Celery中传递连接详细信息

Question

如何使用Celery将用户和密码连接详细信息添加到我的代理中。我不是在使用Django框架，而是在使用Python3。

我试过这个：

app = Celery('tasks',
             broker='sqs://123:123',
             )
app.connection(
    userid="23",
    password="123",
    transport_options="{'region': 'eu-west-1'}"
)

Answer 1

您可以使用config_from_object方法。来自文档：

从对象读取配置，其中对象是对象或要导入的模块的名称。

例如：

celeryconfig.py:

BROKER_TRANSPORT = 'amqp'
BROKER_USER = 'user'
BROKER_PASSWORD = 'password'
BROKER_HOST = 'remote.server.com'
BROKER_PORT = 123
#...

模块内：

app = Celery('tasks')
app.config_from_object('celeryconfig')