celery的使用

安裝celery

1）安裝相關依賴

序列化程式

<code>celery[auth]</code>

用于使用<code>auth</code>安全序列化程式。

<code>celery[msgpack]</code>

用于使用 msgpack 序列化程式。

<code>celery[redis]</code>

使用 Redis 作為消息傳輸或結果後端。

安裝redis

這裡我們使用redis作為celery的broker，作為任務隊列的存儲和結果的存儲。

對于 Redis 支援，您必須安裝其他依賴項。您可以使用<code>celery[redis]</code> bundle一次性安裝 Celery 和這些依賴項：

1）配置

配置很簡單，隻需配置你的 Redis 資料庫的位置：

其中 URL 的格式為：

方案後面的所有字段都是可選的，并且将預設為<code>localhost</code> 端口 6379，使用資料庫 0。

使用ceelry

1）首先我們可以建立一個celery的檔案夾，然後建立一個tasks.py檔案

celery/tasks.py

celery/run_tasks.py

啟動celery

使用flower監控celery任務的執行情況

啟動flower，指定我們的應用，確定你的celery是啟動的。

運作結果：

我們就可以通過5555端口看到celery異步任務的運作情況了

官方位址：https://docs.celeryproject.org/en/latest/django/first-steps-with-django.html

建立celery檔案

根據官方文檔的說明，我們可以直接在Django項目同名的應用下建立celery.py檔案

recruitment/recruitment/celery.py

然後我們需要在這個celery.py檔案所在的目錄的<code>__init__</code>檔案中添加：

添加celery配置

settings/base.py

在别的應用下使用celery執行異步任務 [使用celery異步發送釘釘群消息通知]

首先我們需要在應用下建立一個tasks.py檔案

interview/tasks.py

interview/dingtalk.py

interview.views.py

啟動celery服務

啟動celery服務，到我們的項目根目錄啟動，然後執行

如果需要制定配置檔案，如果在mac下可以執行：

啟動flower監控異步任務