這篇文章給大家介紹怎么在Django中使用Celery執行異步任務，內容非常詳細，感興趣的小伙伴們可以參考借鑒，希望對大家能有所幫助。
項目下新建tasks.py
from celery import Celery
# 創建一個Celery類的實例對象
app = Celery('celery_task.tasks', broker='redis://127.0.0.1:6379/8')
# 定義任務函數
@app.task
def send_register_active_email(message):
with open("D:\\celery\\text.txt", 'a') as f:
f.write("To perform a task..." + message)調用觸發任務
run.py
from celery_tasks.tasks import send_register_active_email
def register():
send_register_active_email.delay("test1\n")
if __name__ == "__main__":
register()在項目目錄下啟動celery
celery -A tasks worker -l info
再運行run.py
如圖，接收到任務并成功執行。
關于怎么在Django中使用Celery執行異步任務就分享到這里了，希望以上內容可以對大家有一定的幫助，可以學到更多知識。如果覺得文章不錯，可以把它分享出去讓更多的人看到。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
