如何在Celery中傳遞連接詳細信息

Question

如何使用Celery可以向我的經紀人添加用戶和密碼連接詳細信息。我不使用Django框架只是Python 3的

我已經試過這樣：

app = Celery('tasks', 
      broker='sqs://123:123', 
      ) 

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

Answer 1

可以使用config_from_object方法。從docs：

從對象中讀取配置，其中對象是對象或 導入一個模塊的名稱。

例如：

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')