解决django-apscheduler和gunicorn重复运行

栏目: Python · 发布时间: 5年前

内容简介:最近有需求需要用到定时任务,我选择了

最近有需求需要用到定时任务,我选择了 django-apscheduler ,但是在开发环境进行自测时发现 同一时间运行了三次

gunicorn 配置如下图,这里的 cpu1 ,刚好启动的进程数为 3

解决django-apscheduler和gunicorn重复运行

gunicorn 在启动的时候开启了三个进程,但是这里的 apscheduler 也就启动三个,这时会 造成定时任务重复运行

解决问题

网上的解决方法主要有两种:

  • gunicorn 启动的时候加上 --preload 参数,或者 preload_app=True ,默认为 False
  • 第二种是使用 的方式来控制

我这里也是使用锁来实现,具体代码如下:

from django.conf import settings
from apscheduler.schedulers.background import BackgroundScheduler
from django_apscheduler.jobstores import DjangoJobStore, register_events, register_job
from django_redis import get_redis_connection

scheduler = BackgroundScheduler()
scheduler.add_jobstore(DjangoJobStore(), "default")
scheduler.remove_all_jobs()

key = "lock"
redis_cli = get_redis_connection(settings.REDIS_CACHE_ALIAS)
data = redis_cli.get(key)
if data is None:
    redis_cli.set(key, "lock", ex=10)
    register_events(scheduler)
    scheduler.start()

启动时设置一个 key ,后面几个进程启动发现 key 已设置就不启动 apscheduler , 设置过期时间为启动后 key 的释放,这里只是一个简单实现思路,可以参考 并发锁 去实现。


以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持 码农网

查看所有标签

猜你喜欢:

本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们

Computational Geometry

Computational Geometry

Mark de Berg、Otfried Cheong、Marc van Kreveld、Mark Overmars / Springer / 2008-4-16 / USD 49.95

This well-accepted introduction to computational geometry is a textbook for high-level undergraduate and low-level graduate courses. The focus is on algorithms and hence the book is well suited for st......一起来看看 《Computational Geometry》 这本书的介绍吧!

SHA 加密
SHA 加密

SHA 加密工具

HEX CMYK 转换工具
HEX CMYK 转换工具

HEX CMYK 互转工具

HEX HSV 转换工具
HEX HSV 转换工具

HEX HSV 互换工具