您好,登錄后才能下訂單哦!
環境準備
windows下啟動redirs server
redis-server.exe redis.windows.conf
celery配置
項目的settings.py文件修改:
# celery 設置 # celery中間人 redis://redis服務所在的ip地址:端口/數據庫號 BROKER_URL = 'redis://127.0.0.1:6379/0' # celery結果返回,可用于跟蹤結果 CELERY_RESULT_BACKEND = 'redis://127.0.0.1:6379/0' # celery內容等消息的格式設置 CELERY_ACCEPT_CONTENT = ['application/json', ] CELERY_TASK_SERIALIZER = 'json' CELERY_RESULT_SERIALIZER = 'json' # celery時區設置,使用settings中TIME_ZONE同樣的時區 CELERY_TIMEZONE = TIME_ZONE
項目文件夾下添加celery.py文件:
# coding:utf-8 from __future__ import absolute_import, unicode_literals from celery import Celery from django.conf import settings import os # 獲取當前文件夾名,即為該Django的項目名 project_name = os.path.split(os.path.abspath('.'))[-1] project_settings = '%s.settings' % project_name # 設置環境變量 os.environ.setdefault('DJANGO_SETTINGS_MODULE', project_settings) # 實例化Celery,網上很多教程這里都是沒有設置broker造成啟動失敗 app = Celery('tasks', broker='redis://127.0.0.1:6379/0') # 使用django的settings文件配置celery app.config_from_object('django.conf:settings') # Celery加載所有注冊的應用 app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)
項目的init.py文件修改:
# 引入celery實例對象 from __future__ import absolute_import, unicode_literals from .celery import app as celery_app __all__ = ['celery_app]
測試代碼
import time from celery import task @task def add(a,b): print("這是任務開始") print(a+b) time.sleep(10) print("這是任務結束")
url配置如下:
path('add', views.add, name="add")
view代碼
from . import tasks def add(request,*args,**kwargs): tasks.add.delay(1,2) result = {'code': 0, 'msg': '這是一個后臺任務'} return JsonResponse(result)
再次配置
在manger.py目錄執行下面的代碼,注意網上的資料大部分執行的命令有問題,造成啟動報錯,比如這個就是錯誤的, python manage.py celery -A celery worker --loglevel=info
,請用下面的命令
celery -A djangoApi worker --pool=solo -l info
啟動項目, python manager.py runserver 0.0.0.0:8081
運行項目
訪問add
查看關鍵日志
[tasks] . api.base.BaseViewTask.task_run . api.tasks.add [2019-04-07 13:26:02,855: INFO/MainProcess] Connected to redis://127.0.0.1:6379/0 [2019-04-07 13:26:02,869: INFO/MainProcess] mingle: searching for neighbors [2019-04-07 13:26:03,911: INFO/MainProcess] mingle: all alone [2019-04-07 13:26:03,926: WARNING/MainProcess] e:\app\python35\lib\site-packages\celery\fixups\django.py:202: UserWarning: Using settings.DEBUG leads to a memory leak, never use this setting in production environments! warnings.warn('Using settings.DEBUG leads to a memory leak, never ' [2019-04-07 13:26:03,926: INFO/MainProcess] celery@PC-20181208QWQO ready. [2019-04-07 13:29:56,889: INFO/MainProcess] Received task: api.tasks.add[9fd98fd0-50ae-427f-8f33-52d1e4b43068] [2019-04-07 13:29:56,894: WARNING/MainProcess] 這是任務開始 [2019-04-07 13:29:56,895: WARNING/MainProcess] 3 [2019-04-07 13:30:06,896: WARNING/MainProcess] 這是任務結束 [2019-04-07 13:30:06,898: INFO/MainProcess] Task api.tasks.add[9fd98fd0-50ae-427f-8f33-52d1e4b43068] succeeded in 10.0s: None
其他
如何結合前端,如ajax來聯合使用?
以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持億速云。
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。