10

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

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

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

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

尽管使用 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()
4

2 回答 2

5

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

于 2014-11-14T12:22:16.277 回答
1

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

于 2014-06-23T15:45:28.557 回答