python - 在 uwsgi 应用程序中启动 APScheduler 最终会为每个 worker 分配一个调度程序吗？

Question

我有一个 flask 应用程序，我需要 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 堆栈中部署调度程序。