91超碰碰碰碰久久久久久综合_超碰av人澡人澡人澡人澡人掠_国产黄大片在线观看画质优化_txt小说免费全本

溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

django celery redis使用具體實踐

發布時間:2020-09-29 14:29:37 來源:腳本之家 閱讀:202 作者:望月成三人 欄目:開發技術

環境準備

  • python3.5.4
  • windows redis
  • pip install celery
  • pip install redis

windows下啟動redirs server

redis-server.exe redis.windows.conf

django celery redis使用具體實踐

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]

測試代碼

  • 如:在app01(項目名)/tasks.py:
  • 關于task,并不是一定要把所有的task放在tasks.py,可以放在其他類里面,只要在函數上加@task即可
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

django celery redis使用具體實踐

查看關鍵日志

[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來聯合使用?

  • 表中我加了個extend字段,每次在執行耗時任務后,頁面按鈕根據extend字段值進行判斷
  • 如1表示執行中,0表示沒有執行,2執行完成,來判定按鈕是否可以再次點擊等

以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持億速云。

向AI問一下細節

免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

AI

庆阳市| 临海市| 雷州市| 万全县| 海门市| 盐山县| 米泉市| 武定县| 枣阳市| 承德市| 玉溪市| 万年县| 桃园市| 宁阳县| 邯郸县| 蕉岭县| 南投县| 海宁市| 河南省| 阜城县| 苏州市| 胶州市| 筠连县| 图木舒克市| 肥乡县| 怀仁县| 明光市| 上犹县| 肥西县| 长兴县| 和田市| 丰都县| 文登市| 镇宁| 安岳县| 会理县| 南宁市| 徐汇区| 新余市| 白河县| 竹山县|