AWS RDS到AWS ES

JDe*_*Dev 3 java elasticsearch amazon-kinesis aws-lambda amazon-kinesis-firehose

要求:在插入/更新到特定表时,创建一个数据流并将其推送到弹性搜索。

以为 AWS RDS(MariaDb)----- 插入/更新以说出用户表 ---> AWS Kinesis流-使用AWS Lambda- > AWS ES

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

das*_*mug 5

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

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

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

参考:从Amazon Aurora数据库集群调用Lambda函数


如果您不是使用Aurora,而是使用MySQL或MariaDB,则建议切换此功能是否对您的应用程序确实很重要。

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