在 Linux 上調試 Celery 應用,你可以遵循以下步驟:
安裝必要的工具和庫: 確保你已經安裝了 Python、pip 和 Celery。此外,你還需要安裝一個消息代理(例如 RabbitMQ 或 Redis)來處理任務隊列。
創建一個簡單的 Celery 應用:
創建一個名為 tasks.py 的文件,其中包含一個簡單的 Celery 任務。例如:
from celery import Celery
app = Celery('tasks', broker='pyamqp://guest@localhost//')
@app.task
def add(x, y):
return x + y
celeryconfig.py 的文件,其中包含 Celery 的配置信息。例如:BROKER_URL = 'pyamqp://guest:guest@localhost:5672/'
CELERY_RESULT_BACKEND = 'rpc://'
CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZER = 'json'
CELERY_ACCEPT_CONTENT = ['json']
CELERY_TIMEZONE = 'Europe/Oslo'
CELERY_ENABLE_UTC = True
celery -A tasks worker --loglevel=info
這將啟動一個 Celery 工作進程,該進程將開始監聽任務隊列并執行任務。
import pdb; pdb.set_trace()
然后,運行你的 Celery 應用。當代碼執行到斷點時,調試器將暫停執行并允許你逐步執行代碼、檢查變量值等。
查看日志: Celery 會生成日志,你可以在其中查看任務執行情況。默認情況下,日志將輸出到標準輸出(例如終端)。你還可以將日志輸出到文件或其他日志系統,以便更好地分析和調試。
使用 Celery Flower: Celery Flower 是一個實時監控和管理 Celery 集群的工具。你可以使用它來查看任務的執行情況、工作進程的狀態等。要使用 Celery Flower,請先安裝它:
pip install flower
然后,使用以下命令啟動 Celery Flower:
flower -A tasks --port=5555
現在,你可以在瀏覽器中訪問 http://localhost:5555 以查看 Celery Flower 的界面。
通過遵循這些步驟,你可以在 Linux 上調試 Celery 應用并找到潛在的問題。