1. 程式人生 > 其它 >django中使用celery流程

django中使用celery流程

django中使用celery的方式

"""

  1. 專案下建立一個目錄(名字任意)

  2. 目錄下建立一個celery的啟動檔案
    from celery import Celery
    celery = Celery(name)
    celery.config_from_object("celer的配置檔案寫路徑+.分割") # 載入配置檔案
    celery.autodiscover_tasks(["目錄.目錄"])

  3. 建立一個config.py配置檔案

    任務佇列的連結地址

    broker_url = 'redis://127.0.0.1:6379/15'

    結果佇列的連結地址

    result_backend = 'redis://127.0.0.1:6379/14'

  4. 目錄下在建立一個目錄,裡面建立一個tasks.py 檔案
    from 檔案.啟動檔案 import celery
    @celery.task
    def send_sms():
    print("非同步傳送簡訊")

  5. tasks.py檔案中寫任務

  6. 控制檯啟動celery命令
    celery -A 目錄.啟動檔案 worker -- loglevel=info

  7. 在專案中呼叫非同步任務
    1.1 匯入非同步任務函式
    1.2 function.delay() 執行非同步任務

  8. 在django外部載入django環境
    import os
    os.environ.setdefault("DJANGO_SETTINGS_MODULE", "renranapi.settings.dev")
    import django
    django.setup()
    """