在django-xadmin中APScheduler的启动初始化实例

环境: python3.5.x + django1.9.x + xadmin-for-python3

APScheduler做为一个轻量级和使用量很多的后台任务计划(scheduler)包，可以方便的随系统启动/关闭而启动/关闭，如果整合到django中，启动APScheduler的代码该写在哪里好呢，

以下几个方式供参考：

1. （推荐）自定义Middleware，非常类似Java中的Filter，缺点是要有URL访问才会触发启动，如果系统还没有启动完就访问了URL会触发__init__多次调用（多次http同时请求造成），可以通过threading的lock同步代码和状态限制执行一次

class StartupMiddleware(object):
 def __init__(self):
  #启动后台任务APScheduler
  init_scheduler()

  from django.core.exceptions import MiddlewareNotUsed
  raise MiddlewareNotUsed #TIP 抛出此异常，则Django将从 middleware 栈中移出该 middleware，请求就不会经过此middleware

 def process_request(self, request):
  print("*****enter startup middleware")
scheduler = None
def init_scheduler():
 global scheduler
 lock = threading.Lock() # TIP 多线程同步代码
 with lock:
  if scheduler and scheduler.running:
   print('*****APScheduler is already started, pid:{}, tid:{}'.format(os.getpid(), threading.current_thread().getName()))
   return scheduler
  executors = {
   'default': ThreadPoolExecutor(5),#线程模式下进程池大小
   'processpool': ProcessPoolExecutor(5),#进程模式下进程池大小
  }
  job_defaults = {
   'coalesce': True, #如果有几次未执行，条件可以时是否只执行一次
   'max_instances': 1, #同一个job同一时间最多有几个实例再跑
  }

  scheduler = BackgroundScheduler(executors=executors, job_defaults=job_defaults, timezone=timezone(TIME_ZONE))

  scheduler.add_job(...)
  scheduler.start()
  return scheduler

2. 应用中的settings.py文件，django在开发环境默认会启动两个python进程(对于开发环境还是很实用的，改代码后会自动重启)，放settings.py中的代码会被这两个python进程都调用一次，当然可以通过--reload参数只启动一个python进程，另外加载settings.py时部分app还未loaded，限制了应用的代码。

3. 顶层的urls文件， 这个不管你django启动时是一个进程还是两个进程，urls文件也只会被加载一次，但存在的缺陷就是在执行makemigrations这样的命令时，会同样出现app还未loaded的错...

以上这篇在django-xadmin中APScheduler的启动初始化实例就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持我们。

赞 (0)

相关推荐

  • django+xadmin+djcelery实现后台管理定时任务

    继上一篇中间表的数据是动态的,图表展示的数据才比较准确.这里用到一个新的模块Djcelery,安装配置步骤如下: 1.安装 redis==2.10.6 celery==3.1.23 django-celery==3.1.17 flower==0.9.2 supervisor==3.3.4 flower用于监控定时任务,supervisor管理进程,可选 2.配置 settings.py中添加以下几行: #最顶头加上 from __future__ import absolute_import #

  • Django xadmin开启搜索功能的实现

    应用目录下adminx.py class EmailVerifyRecordAdmin(object): search_fields = ['code','email','send_type'] 过滤器搜索 class EmailVerifyRecordAdmin(object): list_filter = ['code','email','send_type','send_time'] 以上这篇Django xadmin开启搜索功能的实现就是小编分享给大家的全部内容了,希望能给大家一个参考,

  • 解决django-xadmin列表页filter关联对象搜索问题

    环境:xadmin-for-python3 python3.5.2 django1.9.12 问题描述:Product ProductSku两个实体,ProductSku FK外键关联Product ,Product 列表页的filter不支持productsku__sku_code的搜索,主要页面加载时报Product has no field named 'sku_code' 解决办法: xadmin\util.py文件中def get_model_from_relation(field):

  • Django 实现xadmin后台菜单改为中文

    应用目录下apps.py class OperationConfig(AppConfig): name = 'operation' verbose_name = u"用户操作" __init__.py default_app_config = "operation.apps.OperationConfig" 以上这篇Django 实现xadmin后台菜单改为中文就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持我们.

  • 在django-xadmin中APScheduler的启动初始化实例

    环境: python3.5.x + django1.9.x + xadmin-for-python3 APScheduler做为一个轻量级和使用量很多的后台任务计划(scheduler)包,可以方便的随系统启动/关闭而启动/关闭,如果整合到django中,启动APScheduler的代码该写在哪里好呢, 以下几个方式供参考: 1. (推荐)自定义Middleware,非常类似Java中的Filter,缺点是要有URL访问才会触发启动,如果系统还没有启动完就访问了URL会触发__init__多次调

  • django xadmin中form_layout添加字段显示方式

    需求: 用的是django的框架,想显示一个基本固定的页面,用到了form_layout 上图的ROW中添加的是model中的字段名,可以显示对应的内容,如果想一行显示多个,可以写成 Row('Flow_type', 'Demand_name'),效果如下图(图片是别人的,借鉴一下) 想正常的显示,还有最后一步就是在把你需要展示的ROW中的字段,放在fields中(部分截取了一下) 补充知识:xadmin 编辑页隐藏字段 引用xadmin 的fieldSet 对不想显示的字段添加**{"styl

  • django项目中使用手机号登录的实例代码

    本文使用聚合数据的短信接口,需要先获取到申请接口的appkey和模板id 项目目录下创建ubtils文件夹,定义返回随机验证码和调取短信接口的函数 function.py文件 import random import re # 随机数 def range_num(num): # 定义一个种子,从这里面随机拿出一个值,可以是字母 seeds = "1234567890" # 定义一个空列表,每次循环,将拿到的值,加入列表 random_num = [] # choice函数:每次从see

  • django API 中接口的互相调用实例

    我就废话不多说了,还是直接上代码吧! url = "http://%s:%s/api-token-auth/" % (ip, port) query_args = { "username": username, "password": password } resp = requests.post(url=url, data=query_args) token = json.loads(resp.text)["token"]

  • Django中在xadmin中集成DjangoUeditor过程详解

    Django中在xadmin中集成DjangoUeditor过程详解

    环境 python版本:3.6 django:1.10.8 1.下载xadmin https://github.com/sshwsfc/xadmin 下载DjangoUeditor https://github.com/twz915/DjangoUeditor3 2.直接将xadmin和DjangoUeditor集成在pycharm里,在项目下新建一个文件夹extra_apps,将与xadmin.DjangoUeditor的同名文件复制在extra_apps下 3.在settings.py里注册

  • 在Python的Django框架中simple-todo工具的简单使用

    缘起 simple-todo最早是web.py一个中文教程的例子.后来Uliweb的作者limodou 认为这个教程很不错,于是有了Uliweb版的simple-todo.接着又有了Bottle版和Flask版.这俨然成了一个FrameworksShow项目.既然是FrameworksShow, 那Django的总不应当缺了吧. simple-todo: 一个简易的 todo 程序 http://simple-is-better.com/news/309 Simple Todo (Uliweb

  • 基于多进程中APScheduler重复运行的解决方法

    问题 在一个python web应用中需要定时执行一些任务,所以用了APScheduler这个库.又因为是用flask这个web框架,所以用了flask-apscheduler这个插件(本质上与直接用APScheduler一样,这里不作区分). 在开发中直接测试运行是没有问题的,但是用gunicorn部署以后发生了重复运行的问题: 每个任务在时间到的时刻会同时执行好几遍. 注意了一下重复的数量,恰恰是gunicorn里配置的worker进程数量,显然是每个worker进程都启动了一份schedu

  • 详解Python的Django框架中manage命令的使用与扩展

    [简介] django-admin.py是Django的一个用于管理任务的命令行工具.本文将描述它的大概用法. 另外,在每一个Django project中都会有一个manage.py.manage.py是对django-admin.py的简单包装,它额外帮助我们做了两件事情: 它将你的project的包放到sys.path中 它将DJANGO_SETTINGS_MODULE环境变量设置为了你的project的setting.py文件的位置. 如果你是通过setup.py工具来安装Django的

  • 在Django框架中运行Python应用全攻略

    我们来假定下面的这些概念.字段和关系: 一个作者有姓,有名及email地址. 出版商有名称,地址,所在城市.省,国家,网站. 书籍有书名和出版日期. 它有一个或多个作者(和作者是多对多的关联关系[many-to-many]), 只有一个出版商(和出版商是一对多的关联关系[one-to-many],也被称作外键[foreign key]) 第一步是用Python代码来描述它们. 打开由`` startapp`` 命令创建的models.py 并输入下面的内容: from django.db imp

  • Struts2中实现web应用的初始化实例详解

    Struts2中实现web应用的初始化实例详解 在JavsSE中,main方法为应用提供了入口,而在Android中,我们可以使用Application对于整个应用的生命周期进行管理,那么在基于Struts2的JavaEE应用中,如何实现类似的功能呢. 其中一种比较好的方式,是通过实现ServletContextListener接口进行坚挺,重写contextInitialized方法,实现自己需要进行的初始化操作,之后在web.xml中添加相应的listner,tomcat在启动服务时会调用相

随机推荐