在 Linux 上部署 Celery 應用需要經過以下幾個步驟:
安裝依賴: 首先,確保你的系統已經安裝了 Python、pip 和相關的依賴庫。然后,使用 pip 安裝 Celery 及其相關組件。例如:
pip install celery
創建 Celery 實例: 在你的項目中創建一個新的 Python 文件(例如:celery.py),并在其中定義一個 Celery 實例。例如:
from celery import Celery
app = Celery('myapp',
broker='pyamqp://guest@localhost//',
backend='rpc://',
include=['myapp.tasks'])
if __name__ == '__main__':
app.start()
編寫任務: 在你的項目中創建一個名為 tasks.py 的文件,并在其中定義你的任務函數。例如:
from myapp.celery import app
@app.task
def add(x, y):
return x + y
配置消息代理: 根據你的需求選擇一個消息代理(例如:RabbitMQ、Redis 等)。安裝并配置相應的消息代理服務器,并在 Celery 實例中指定消息代理的 URL。
配置結果后端: 根據你的需求選擇一個結果后端(例如:RabbitMQ、Redis、Memcached 等)。安裝并配置相應的后端服務器,并在 Celery 實例中指定結果后端的 URL。
啟動 Celery worker: 在項目根目錄下運行以下命令啟動 Celery worker:
celery -A myapp.celery worker --loglevel=info
調用任務:
在你的應用程序中,使用 apply_async
或 delay
方法調用 Celery 任務。例如:
from myapp.tasks import add
result = add.delay(4, 4)
print(result.get())
監控和管理: 可以使用 Flower 或其他工具來監控和管理 Celery 集群。安裝并配置相應的工具,并在需要時啟動它們。
部署: 將你的應用程序部署到生產環境。你可以使用 WSGI 服務器(例如:Gunicorn、uWSGI 等)和進程管理工具(例如:systemd、supervisord 等)來管理你的應用程序和 Celery worker。
日志和監控: 配置日志記錄和監控工具,以便在出現問題時能夠迅速定位和解決問題。