8wDlpd.png
8wDFp9.png
8wDEOx.png
8wDMfH.png
8wDKte.png

架构建议:如何实时监听数据库变化?

Rowandinho 1月前

9 0

我正在尝试开发一个系统,当新条目到达集中式数据库 (MySQL) 时,会存储一些预测/估计结果。我有多个微服务写入该数据库,

我正在尝试开发一个系统,当新条目到达集中式数据库 (MySQL) 时,一些预测/估计结果会​​存储其中。我有多个微服务写入该数据库,我已修补了将记录推送到 Kafka 的代码,而 Kafka 的消费者正在估算并将结果推送回数据库。

我的问题是:

  1. 多个微服务是用 Node 或 Python 编写的,所以我需要用两者来编写逻辑。
  2. 由于在多个地方注入代码,维护正成为一个问题。

潜在解决方案 1. 创建另一个微服务,成为 Kafka 的生产者。

我们能否拥有管理更加完善的系统?

帖子版权声明 1、本帖标题:架构建议:如何实时监听数据库变化?
    本站网址:http://xjnalaquan.com/
2、本网站的资源部分来源于网络,如有侵权,请联系站长进行删除处理。
3、会员发帖仅代表会员个人观点,并不代表本站赞同其观点和对其真实性负责。
4、本站一律禁止以任何方式发布或转载任何违法的相关信息,访客发现请向站长举报
5、站长邮箱:yeweds@126.com 除非注明,本帖由Rowandinho在本站《mysql》版块原创发布, 转载请注明出处!
最新回复 (0)
  • 您可能需要检查一下 Change Data Management 。您可以使用 Debezium 实用程序来监听数据库上发生的事件并将其推送到 Kafka 主题。

    工作流程可以概括为:

    1. 记录到达 DB。
    2. 事务日志由数据库写入。
    3. Debezium 连接器跟踪日志,并通过 Kafka 连接将更改推送到 Kafka。
    4. 您现在可以订阅Kafka主题并估算记录。

    收获:

    1. 即使您的 Debezium 出现故障,当它恢复时,它也会提供故障期间发生的所有更改。从这个意义上讲,它具有容错能力。
    2. 您将监听集中式数据库,而不是从多个服务推送消息。这实现了单一事实来源原则。
返回
作者最近主题: