8wDlpd.png
首页
8wDFp9.png
分类
8wDEOx.png
8wDMfH.png
消息
8wDKte.png
我的
  2. mysql
  3. 架构建议：如何实时监听数据库变化？

架构建议：如何实时监听数据库变化？

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） X
正在加载信息~
最新回复 (0)
  • 引用 2楼

    您可能需要检查一下 Change Data Management 。您可以使用 Debezium 实用程序来监听数据库上发生的事件并将其推送到 Kafka 主题。

    工作流程可以概括为：

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

    收获：

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