欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

django+xadmin+djcelery實現(xiàn)后臺管理定時任務

 更新時間:2018年08月14日 09:00:30   作者:落葉雖美只活一世  
這篇文章主要介紹了django+xadmin+djcelery實現(xiàn)后臺管理定時任務,小編覺得挺不錯的,現(xiàn)在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧

繼上一篇中間表的數(shù)據(jù)是動態(tài)的,圖表展示的數(shù)據(jù)才比較準確。這里用到一個新的模塊Djcelery,安裝配置步驟如下:

1.安裝

redis==2.10.6

celery==3.1.23

django-celery==3.1.17

flower==0.9.2

supervisor==3.3.4

flower用于監(jiān)控定時任務,supervisor管理進程,可選

2.配置

settings.py中添加以下幾行:

#最頂頭加上
from __future__ import absolute_import

# celery settings
import djcelery
djcelery.setup_loader()
BROKER_URL = 'redis://localhost:6379'
# BROKER_URL = 'redis://:密碼@主機地址:端口號/數(shù)據(jù)庫號'
CELERYBEAT_SCHEDULER = 'djcelery.schedulers.DatabaseScheduler' # 定時任務
CELERY_RESULT_BACKEND = 'djcelery.backends.database:DatabaseBackend'
CELERY_RESULT_BACKEND = 'redis://localhost:6379'
CELERY_ACCEPT_CONTENT = ['application/json']
CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZER = 'json'
CELERYD_MAX_TASKS_PER_CHILD = 40
CELERY_TIMEZONE = 'Asia/Shanghai'

INSTALLED_APPS = [
  'djcelery',# 添加djcelery
]

3.注冊定時任務的幾個表

from __future__ import absolute_import, unicode_literals
from djcelery.models import (
  TaskState, WorkerState,
  PeriodicTask, IntervalSchedule, CrontabSchedule,
)
from xadmin.sites import site
site.register(IntervalSchedule) # 存儲循環(huán)任務設置的時間
site.register(CrontabSchedule) # 存儲定時任務設置的時間
site.register(PeriodicTask) # 存儲任務
site.register(TaskState) # 存儲任務執(zhí)行狀態(tài)
site.register(WorkerState) # 存儲執(zhí)行任務的worker

4.主應用下添加celery.py

__init__.py修改如下:

# __init__.py
from __future__ import absolute_import
from .celery import app as celery_app


# celery.py
from __future__ import absolute_import

import os
from celery import Celery, platforms
from django.conf import settings

# set the default Django settings module for the 'celery' program.
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'hermes.settings')

# hermes主應用名
app = Celery('hermes')
platforms.C_FORCE_ROOT = True

app.config_from_object('django.conf:settings')
app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)

@app.task(bind=True)
def debug_task(self):
  print('Request: {0!r}'.format(self.request))

5.添加任務 應用下添加tasks.py

from __future__ import absolute_import

from celery import task
import time

from .channels import Cache_data_to_redis

# 更新指定日期數(shù)據(jù)到sms_organizationcount
@task
def readAndWrite(begin,end):
  begin = str(begin)[:4] + '-' + str(begin)[4:6] + '-' + str(begin)[6:8]
  end = str(end)[:4] + '-' + str(end)[4:6] + '-' + str(end)[6:8]
  i = 0
  begin_time = time.time()
  read = Cache_data_to_redis().connection
  Rcursor = read.cursor()
  query = "SELECT id from sms_organizationcount WHERE alia_date_time between '"
  query += begin
  query += "' and '"
  query += end
  query += "'"
  readSql = "SELECT alia_month_time, alia_date_time, count(*) as total_nums, count(t.`status`=2 or null) as error_nums, name FROM \
       (select *, DATE_FORMAT(req_time,'%Y-%m') as alia_month_time, DATE_FORMAT(req_time,'%Y-%m-%d') as alia_date_time, \
       LEFT(body,LOCATE('】',body)) as name from sms_smslog where LOCATE('】',body) >0 \
       and LEFT(body,1)='【' and DATE_FORMAT(req_time,'%Y-%m-%d') between '"
  readSql += begin
  readSql += "' and '"
  readSql += end
  readSql += "')"
  readSql += " as t GROUP BY alia_date_time , name;"
  Rcursor.execute(readSql)
  readResult = Rcursor.fetchall()
  Rcursor.execute(query)
  query_result = Rcursor.fetchall()
  deleteSql = "delete from sms_organizationcount where alia_date_time between '%s' and '%s'" % (begin,end)
  if query_result:
    delete_record = Cache_data_to_redis().connection
    Dcursor = delete_record.cursor()
    Dcursor.execute(deleteSql)
    delete_record.commit()
    delete_record.close()
    for value in readResult:
    write = Cache_data_to_redis().connection
    Wcursor = write.cursor()
    writeSql = "INSERT into sms_organizationcount (alia_month_time, alia_date_time, total_nums, error_nums, `name`) " \
          " VALUES ('%s', '%s', '%s', '%s', '%s' )" %\
          (value['alia_month_time'], value['alia_date_time'], value['total_nums'], value['error_nums'], value['name'])
    try:
      Wcursor.execute(writeSql)
      i += 1
      write.commit()
    except:
      write.rollback()
    write.close()
  read.close()
  end_time = time.time()
  pass_time = end_time - begin_time
  return i, pass_time

6.最終效果如下圖:

7.終端啟動celery命令:

# 查看注冊的task
celery -A hermes inspect registered
# 啟動
python manage.py celery -A django_celery_demo worker -B  # django_celery_demo為celery和setting所在文件夾名

#celery_beat起不來
# 動態(tài)的輸出啟動進程時的輸出
supervisorctl tail programname stdout


# flower監(jiān)控celery
python manage.py celery flower
ip:5555

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

相關文章

  • python中matplotlib調整圖例位置的方法實例

    python中matplotlib調整圖例位置的方法實例

    在matplotlib中,一般圖例默認是在圖表內部的,如果要放置到圖例外面,需要對坐標進行指定,下面這篇文章主要給大家介紹了關于python中matplotlib調整圖例位置的相關資料,需要的朋友可以參考下
    2022-06-06
  • 一起來學習Python的元組和列表

    一起來學習Python的元組和列表

    這篇文章主要為大家詳細介紹了Python元組和列表,文中示例代碼介紹的非常詳細,具有一定的參考價值,感興趣的小伙伴們可以參考一下,希望能夠給你帶來幫助
    2022-03-03
  • OpenCV凸包檢測和凸缺陷學習示例

    OpenCV凸包檢測和凸缺陷學習示例

    這篇文章主要為大家介紹了OpenCV凸包檢測和凸缺陷學習示例,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪
    2022-06-06
  • Pycharm出現(xiàn)卡頓、反應慢及CPU占用高等問題解決

    Pycharm出現(xiàn)卡頓、反應慢及CPU占用高等問題解決

    相信很多剛開始使用pycharm不太熟練的小伙伴,每天一開機打開pycharm總是卡半天,不知道的還以為是電腦卡了或者啥問題的,下面這篇文章主要給大家介紹了關于Pycharm出現(xiàn)卡頓、反應慢及CPU占用高等問題解決的相關資料,需要的朋友可以參考下
    2023-06-06
  • Flask 入門Web 微框架Hello Flask

    Flask 入門Web 微框架Hello Flask

    這篇文章主要介紹了 Flask 入門Web 微框架Hello Flask,F(xiàn)lask 是一個 Python 實現(xiàn)的 Web 微框架,之所以稱之為微框架,是因為 Flask 核心簡單且易于擴展,有兩個主要依賴,WSGI工具集:Werkzeug和模板引擎:Jinja2,Flask 只保留了 Web 開發(fā)的核心功能,需要的朋友可以參考一下
    2021-11-11
  • python3中datetime庫,time庫以及pandas中的時間函數(shù)區(qū)別與詳解

    python3中datetime庫,time庫以及pandas中的時間函數(shù)區(qū)別與詳解

    這篇文章主要介紹了python3中datetime庫,time庫以及pandas中的時間函數(shù)區(qū)別與詳解,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧
    2020-04-04
  • python實現(xiàn)切割url得到域名、協(xié)議、主機名等各個字段的例子

    python實現(xiàn)切割url得到域名、協(xié)議、主機名等各個字段的例子

    今天小編就為大家分享一篇python實現(xiàn)切割url得到域名、協(xié)議、主機名等各個字段的例子,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧
    2019-07-07
  • 在Python中定義一個常量的方法

    在Python中定義一個常量的方法

    今天小編就為大家分享一篇在Python中定義一個常量的方法,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧
    2018-11-11
  • Python編程實現(xiàn)輸入某年某月某日計算出這一天是該年第幾天的方法

    Python編程實現(xiàn)輸入某年某月某日計算出這一天是該年第幾天的方法

    這篇文章主要介紹了Python編程實現(xiàn)輸入某年某月某日計算出這一天是該年第幾天的方法,涉及Python針對日期時間的轉換與運算相關操作技巧,需要的朋友可以參考下
    2017-04-04
  • 利用Pytorch實現(xiàn)獲取特征圖的方法詳解

    利用Pytorch實現(xiàn)獲取特征圖的方法詳解

    這篇文章主要為大家詳細介紹了如何利用Pytorch實現(xiàn)獲取特征圖,包括提取單個特征圖和提取多個特征圖,文中的示例代碼講解詳細,需要的可以參考一下
    2022-10-10

最新評論