解决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 的释放,这里只是一个简单实现思路,可以参考 并发锁 去实现。


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

查看所有标签

猜你喜欢:

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

超级IP

超级IP

吴声 / 中信出版集团 / 2016-7 / 49.00元

一切商业皆内容,一切内容皆IP! 从迪士尼、airbnb、YouTube、Instagram到微信、Papi酱、芈月传、鹿晗,IP浪潮席卷全球,这不仅仅是互联网领域的革命,更是未来商业的游戏新规则。 IP从泛娱乐形态快速渗透新商业生态全维度,正深化为不同行业共同的战略方法,甚至是一种全新的商业生存方式,即IP化生存。 超级IP的内核,是辨识度极高的可认同的商业符号,它意味着一种对......一起来看看 《超级IP》 这本书的介绍吧!

HTML 压缩/解压工具
HTML 压缩/解压工具

在线压缩/解压 HTML 代码

URL 编码/解码
URL 编码/解码

URL 编码/解码

XML 在线格式化
XML 在线格式化

在线 XML 格式化压缩工具