java - AWS RDS 到 AWS ES

Question

要求:在插入/更新特定表时创建数据流并将其推送到 Elasticsearch 。

想法 AWS RDS(MariaDb) ----- insert/update to say user table ---> AWS Kinesis stream -- 使用 AWS Lambda--> AWS 服务

问题 如何在插入/更新特定表时创建运动流？我可以通过 AWS Lambda 完成吗？

Answer 1

如果您使用的是 Amazon Aurora，则可以执行此操作。

Amazon Aurora 的最新更新之一是支持从存储过程调用 Lambda 函数。

因此，为了实现您的要求，您可以创建一个 SQL 触发器来调用 SQL 存储过程，然后调用 Lambda 函数将数据发送到 Elastic Search。

引用:Invoking a Lambda Function from an Amazon Aurora DB Cluster

交易注意事项:

作为@Ahmad Nabil在 comments below 中指出，触发器可以在事务提交之前执行。因此调用 Lambda 的 SQL 触发器可能不是您想要的。

---

如果您不使用 Aurora，而是使用 MySQL 或 MariaDB，如果此功能对您的应用程序真的很重要，我建议您切换。

如果您使用的数据库不是 Aurora、MySQL 或 MariaDB，则必须重新考虑您的应用程序以将数据并行写入 RDS 和 ElasticSearch。我还推荐以下架构模式:

• Event Sourcing
• CQRS
• An example showing the above two patterns