在 uwsgi 应用程序中启动 APScheduler 最终会为每个工作人员配备一个调度程序吗？

Posted 2023-02-16

【中文标题】在 uwsgi 应用程序中启动 APScheduler 最终会为每个工作人员配备一个调度程序吗？

【英文标题】：Would starting APScheduler in a uwsgi app end up with one scheduler for each worker?

【发布时间】：2014-08-12 17:00:41

【问题描述】：

我有一个烧瓶应用程序，其中我需要 APScheduler 的调度功能。问题是：

在哪里启动调度程序实例？

我使用 uwsgi+nginx 为这个应用程序提供多个 worker，我最终会不会得到多个 Scheduler 实例，而这些实例会相互忽略？如果这是正确的，一个作业会被触发多次，不是吗？

在这种情况下，最好的策略是什么，这样我最终只有一个 Scheduler 实例，并且仍然能够从计划的作业中访问应用程序的上下文？

This question 也有同样的问题，尽管使用的是 gunicorn 而不是 uwsgi，但答案可能相似。

以下是将“app”定义为 uwsgi 可调用应用程序对象的代码。 包含此代码的文件称为 wsgi.py（没关系）。

app = create_app(config=ProductionConfig())

def job_listener(event):
    get_ = "msg from job '%s'" % (event.job)
    logging.info(get_)

# This code below never gets invoked when I check with worker_id() == 1
# The only time it is run is with worker_id() value of 0
app.sched = Scheduler()
app.sched.add_jobstore(ShelveJobStore('/tmp/apsched_%d' % uwsgi.worker_id()), 'file')
app.sched.add_listener(job_listener,
                   events.EVENT_JOB_EXECUTED |
                   events.EVENT_JOB_MISSED |
                   events.EVENT_JOB_ERROR)
app.sched.start()

【参考方案1】：

uWSGI 有一个叫做 mules 的功能（参见：http://uwsgi-docs.readthedocs.org/en/latest/Mules.html），您可以使用它们在 master 下启动一个无法通过套接字访问的脚本。它旨在使用调度程序从主应用程序中卸载工作并用于信号处理，因此它似乎非常适合在 uwsgi 堆栈中部署调度程序。

【参考方案2】：

UWSGI 有一个函数 uwsgi.worker_id()。如果您有条件地在特定工作人员中启动调度程序，您将不会得到多个调度程序实例。

【讨论】：

我假设 worker_id 是在创建时分配的。我如何事先知道我需要使用哪个 id 来启动调度程序？

我不知道他们是怎么分配的。如果它们是按顺序分配的，您可以只使用 worker id 0 或 1（以第一个为准）。

看起来它们确实是按顺序分配的，从 1 开始。

真正的问题是，如果工人 1 被杀死，它会以相同的 ID 重生吗？

我的研究表明，是的，他们会重复使用这些 ID。