Python社区  »  MongoDB

mongodb fetch的可伸缩spring调度程序

PrabaharanKathiresan • 2 年前 • 417 次点击  

我有一个名为A的mongodb集合,在这个集合中有一个名为field1的日期和时间字段。在我的场景中,我必须根据field1收集过期日期和时间的记录。

我想写spring scheduler作业,它每分钟运行一次,从mongodb中获取过期的日期和时间记录,但是当我开始写时,我无法使springscheduler具有可伸缩性。

问题是,在spring scheduler中,如何停止对Kafka主题的重复消息,或者如何在没有任何重复消息的情况下实现可伸缩的调度器?

有没有基于事件的框架来支持我的场景?意味着当记录过期时,它应该立即通知java系统,即类似于spring中的TailableCursorlisteners侦听cappedcollection。

Python社区是高质量的Python/Django开发社区
本文地址:http://www.python88.com/topic/55343
 
417 次点击  
分享到微博
文章 [ 1 ]  |  最新文章 2 年前
Mykhailo Moskura
Reply   •   1 楼
Mykhailo Moskura    2 年前

您可以使用shedlock库,它将确保所有实例中只有一个作业在运行 以下是教程以获取更多信息:

https://www.baeldung.com/shedlock-spring