溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
這篇文章主要講解了Django+Celery如何實現動態配置定時任務，內容清晰明了，對此有興趣的小伙伴可以學習一下，相信大家閱讀完之后會有幫助。
哈嘍，今天給大家分享一篇Django+Celery實現動態配置定時任務，因為最近也是無意間看到一位大佬關于這塊的文章，然后自己覺得不錯，也想學習寫一下，然后最終實現功能是在前端頁面統一管理計劃任務，大家可以在admin管理頁面設置，也可以在自己寫的前端頁面刪除添加編輯，實時生效，還可以監控這些監控任務是否運行成功失敗。
補充：如果大家對celery不熟悉的話，建議先學習celery
一、安裝
1.在Linux系統上安裝模塊
celery (3.1.26.post2) celery-with-redis (3.0) redis (2.10.6) Django (2.1.10) django-celery (3.3.1)
2.遷移生成表
python manage.py migrate
3.查看生成的表，這幾張表是上面執行命令后生成的
二、配置
1.添加apps
INSTALLED_APPS = [ 'django.contrib.admin', 'django.contrib.auth', 'django.contrib.contenttypes', 'django.contrib.sessions', 'django.contrib.messages', 'django.contrib.staticfiles', 'djcelery', #這是要添加的 ]
2.配置django時區
LANGUAGE_CODE = 'en-us' TIME_ZONE = 'Asia/Shanghai' USE_I18N = True USE_L10N = True USE_TZ = False
3.Celery配置
BROKER_URL = 'redis://localhost:6379' #代理人 CELERY_RESULT_BACKEND = 'redis://localhost:6379' #結果存儲地址 CELERY_ACCEPT_CONTENT = ['application/json'] #指定任務接收的內容序列化類型 CELERY_TASK_SERIALIZER = 'json' #任務序列化方式 CELERY_RESULT_SERIALIZER = 'json' #任務結果序列化方式 CELERY_TASK_RESULT_EXPIRES = 12 * 30 #超過時間 CELERY_MESSAGE_COMPRESSION = 'zlib' #是否壓縮 CELERYD_CONCURRENCY = 4 #并發數默認已CPU數量定 CELERYD_PREFETCH_MULTIPLIER = 4 #celery worker 每次去redis取任務的數量 CELERYD_MAX_TASKS_PER_CHILD = 3 #每個worker最多執行3個任務就摧毀，避免內存泄漏 CELERYD_FORCE_EXECV = True #可以防止死鎖 CELERY_ENABLE_UTC = False #關閉時區 CELERYBEAT_SCHEDULER = 'djcelery.schedulers.DatabaseScheduler' # 定時任務調度器
4.在你項目的app下面配置celery.py
import os
from celery import Celery,platforms
from django.conf import settings
os.environ.setdefault('DJANGO_SETTINGS_MODULE','blog.settings')
app = Celery('blog')
app.config_from_object('django.conf:settings')
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)
platforms.C_FORCE_ROOT = True
@app.task(bind=True)
def debug_task(self):
print('Request: {0!r}'.format(self.request))5.配置剛才app下面的__init__.py文件
from __future__ import absolute_import from .celery import app as celery_app
6.在app下面創建一個tasks.py文件
from blog.celery import app @app.task() def get_date(x,y,s): #這里的函數留意一下，后面會用到 print(s) return x + y @app.task() def get_task(): return 'test' @app.task() def get_command_task(): return 'success'
三、啟動
1.進入你項目下面，執行啟動worker，Worker是執行任務的單元，它實時監控消息隊列，如果有任務就獲取任務并執行它。
celery -A autoops worker -l info
2.進入你項目下面，執行啟動beat，beat是定時把這個任務扔到隊列中
celery -A autoops beat -l info
3.啟動你的django項目
python manage.py runserver 192.168.10.133:8001
4.頁面展示
4.1這個是admin頁面下的，然后我自己重新寫了，大家也可以自己寫一個，admin和我自己寫的頁面實現的功能其實是一模一樣的。
4.2.對應admin頁面的crontabs
添加周期
編輯修改周期
5.tasks任務
5.1.大家可以看到我添加了一個名為測試的任務，每隔一分鐘執行一次，任務模板其實就是你寫的tasks文件里面函數
看一下worker進程日志輸出
四、監控計劃任務
celery作為一個分布式異步任務隊列管理工具，通過界面化的方式來進行管控任務的執行狀態和查看任務執行結果
flower作為web頁面來管理celery后臺任務，和任務隊列是隔離的，也就是flower的運行與否并不會影響到任務隊列的真正執行，但是flower中可以通過API接口來管理celery中的任務執行。
4.1安裝flower，監控celery計劃任務
pip3 install flower==0.9.2 -i http://pypi.douban.com/simple --trusted-host pypi.douban.com pip install tornado==5.1.1 celery flower -A blog --port=5555 #進入項目目錄啟動flower
4.2打開瀏覽器，輸入http://ip:5555 查看
Name: 表示該任務的名稱，默認規則為該函數的路徑規則，例如 {模塊名}.{文件名}.{函數名}
UUID: 表示一個唯一字符串ID用于表示該任務
State: 表示該任務的狀態，包括： SUCCESS / FAILURE / STARTED / RECEIVED
SUCCESS 表示該任務執行完畢且成功
FAILURE 表示該任務執行失敗
STARTED 表示該任務正在執行
RECEIVED 表示該任務在worker中，只是被接收而已
args: 表示該任務的列表參數
kwargs: 表示該任務的字典參數
Result: 表示該任務函數的返回結果
Received: 表示該任務在worker接收到的時間
Started: 表示該任務在worker開始執行的時間
Runtime: 表示該任務在worker真正執行的耗時（單位：秒）
Worker: 表示該任務所在的worker名稱
看完上述內容，是不是對Django+Celery如何實現動態配置定時任務有進一步的了解，如果還想學習更多內容，歡迎關注億速云行業資訊頻道。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
