iT邦幫忙

2023 iThome 鐵人賽

DAY 23
0
Modern Web

30Day啟動!!系列 第 23

Day23- Celery安裝與設定

  • 分享至 

  • xImage
  •  

什麼是 Celery?
Celery 是一個 Python 庫,用於處理異步任務。它允許你將耗時的任務移出主要應用程式進程,以提高性能和可擴展性。Celery 提供了一個簡單而強大的方式來定義、調度和執行異步任務,這些任務可以是任何 Python 函數。

步驟 1:安裝 Celery
首先,我們需要安裝 Celery 和相關的套件。確保你的 Python 環境已經設置好。

你可以使用 pip 安裝 Celery:
pip install celery

步驟 2:創建一個 Celery 專案
接下來,我們將創建一個簡單的 Celery 專案。首先,在你的專案目錄中創建一個名為 celery_example.py 的 Python 檔案。

celery_example.py

from celery import Celery

建立 Celery 實例

app = Celery('celery_example', broker='pyamqp://guest@localhost//')

定義一個簡單的 Celery 任務

@app.task
def add(x, y):
return x + y

在這個示例中,我們建立了一個 Celery 實例 app,並定義了一個名為 add 的 Celery 任務,該任務接受兩個參數並返回它們的總和。

步驟 3:執行 Celery 任務
現在,你已經安裝了 Celery,並創建了一個簡單的 Celery 專案。接下來,我們將學習如何執行這個 Celery 任務。

首先,啟動 Celery worker。在專案目錄中執行以下命令:

celery -A celery_example worker --loglevel=info

這會啟動一個 Celery worker,等待接受任務。

現在,你可以在 Python 中使用 Celery 來執行你的任務:
from celery_example import add

result = add.delay(4, 6)
print(result.get())

這個代碼將 4 和 6 傳遞給 add 任務,並獲得結果。你應該看到 10 被打印出來,這是 add 任務的返回值。

這就是入門 Celery 的第一步!在下一篇文章中,我們將更深入地探討如何定義和調度不同類型的 Celery 任務。


上一篇
Day22-合併和聯接數據
下一篇
Day24-定義和執行 Celery 任務
系列文
30Day啟動!!30
圖片
  直播研討會
圖片
{{ item.channelVendor }} {{ item.webinarstarted }} |
{{ formatDate(item.duration) }}
直播中

尚未有邦友留言

立即登入留言