解决django-apscheduler和gunicorn重复运行

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

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

最近有需求需要用到定时任务,我选择了 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 的释放,这里只是一个简单实现思路,可以参考 并发锁 去实现。


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

查看所有标签

猜你喜欢:

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

另一个地球

另一个地球

[美]马克·格雷厄姆、威廉·H·达顿 / 胡泳、徐嫩羽 / 电子工业出版社 / 2015-10-1 / 78

互联网在日常工作和生活中扮演日益重要的角色,互联网将如何重塑社会?本书通过汇集有关互联网文化、经济、政治角色等问题的研究成果,提供了特定社会制度背景下解决这一问题的根本办法。 关于互联网的研究是蓬勃发展的崭新领域,牛津大学互联网研究院(OII)作为创新型的跨学科学院,自成立起就专注于互联网研究。牛津大学互联网研究院关于互联网+社会的系列讲座在一定程度上塑造了互联网+社会。本书内容基于不同学科......一起来看看 《另一个地球》 这本书的介绍吧!

MD5 加密
MD5 加密

MD5 加密工具

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

HEX HSV 互换工具

HSV CMYK 转换工具
HSV CMYK 转换工具

HSV CMYK互换工具