我想就以下情况请求提供信息、文件、方法或解决方案:
1.表A中,有大量的数据。表A中的记录有2个字段:created_time(记录创建时间)和 deadline_time(记录处理时间)。
当其他记录的到期日临近或处理已过期时,如何向用户发送通知?
我的系统使用Kafka来处理基于事件的消息,并将它们发送给用户。但是在静态数据的另一种情况下,不会生成其他事件。
我在想一个解决方案,那就是使用连续扫描,如果一条消息接近关键或过时,就发送Kafka。但这似乎不是很好,因为为了确保负载平衡,我在同时运行的许多模块上使用了许多进程,这会相互冲突。这个问题还有别的解决办法吗?
非常感谢你的帮助
1条答案
按热度按时间r55awzrz1#
cron任务是否不符合您的要求?如果是,原因是什么?比如每5分钟运行一次,然后得到一个应该发送的记录列表?
另一种解决方案是在保存后在内存中记住deadline_time,在队列中按deadline_time排序,并使用排序后的队列。