在APSchedule的另一个作业中添加作业



我在FastAPI应用程序中使用APScheduler。我有一个表,用于存储异步任务。然后,使用APScheduler,我想每小时读取一次该表,并将新作业(表中每行一个(添加到队列中。这些工作很轻松,所以我觉得用芹菜太浪费时间了。然而,我很难在APScheduler的另一个作业中启动一个作业。所以,问题是如何将一个作业添加到另一个作业中?任何想法或帮助都将不胜感激。

我也遇到过这个问题,一个简单的解决方案是将调度器作为作业模块中可用的全局变量。您可能还必须使用内存存储,因为它允许传递不可序列化的对象。

您也可以将调度程序传递给作业,只要作业在不需要序列化参数的执行器上运行即可。

例如,您可以在asyncio执行器上运行一个周期性作业,该作业将调度程序作为参数,并向其中添加更多作业,这些作业将与ProcessPool执行器一起运行。

有关更多信息,请参阅Gitter频道中的讨论

最新更新