django中使用celery流程
阿新 • • 發佈:2022-05-10
django中使用celery的方式
"""
-
專案下建立一個目錄(名字任意)
-
目錄下建立一個celery的啟動檔案
from celery import Celery
celery = Celery(name)
celery.config_from_object("celer的配置檔案寫路徑+.分割") # 載入配置檔案
celery.autodiscover_tasks(["目錄.目錄"]) -
建立一個config.py配置檔案
任務佇列的連結地址
broker_url = 'redis://127.0.0.1:6379/15'
結果佇列的連結地址
result_backend = 'redis://127.0.0.1:6379/14'
-
目錄下在建立一個目錄,裡面建立一個tasks.py 檔案
from 檔案.啟動檔案 import celery
@celery.task
def send_sms():
print("非同步傳送簡訊") -
tasks.py檔案中寫任務
-
控制檯啟動celery命令
celery -A 目錄.啟動檔案 worker -- loglevel=info -
在專案中呼叫非同步任務
1.1 匯入非同步任務函式
1.2 function.delay() 執行非同步任務 -
在django外部載入django環境
import os
os.environ.setdefault("DJANGO_SETTINGS_MODULE", "renranapi.settings.dev")
import django
django.setup()
"""