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

Question

我有一个烧瓶应用程序，其中我需要 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()

Answer 1

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

Answer 2

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