JDe*_*Dev 3 java elasticsearch amazon-kinesis aws-lambda amazon-kinesis-firehose
要求:在插入/更新到特定表时,创建一个数据流并将其推送到弹性搜索。
以为 AWS RDS(MariaDb)----- 插入/更新以说出用户表 ---> AWS Kinesis流-使用AWS Lambda- > AWS ES
问题如何在插入/更新到特定表时创建运动学流?我可以通过AWS Lambda吗?
如果您使用的是Amazon Aurora,则可以执行此操作。
Amazon Aurora中的最新更新之一是支持从存储过程中调用Lambda函数。
因此,要实现您的需求,您可以创建一个SQL触发器,该触发器调用SQL存储过程,然后调用Lambda函数,该函数将数据发送到Elastic Search。
参考:从Amazon Aurora数据库集群调用Lambda函数
如果您不是使用Aurora,而是使用MySQL或MariaDB,则建议切换此功能是否对您的应用程序确实很重要。
如果使用的数据库不是Aurora,MySQL或MariaDB,则必须重新考虑您的应用程序以将数据并行写入RDS和ElasticSearch。我还建议以下架构模式:
| 归档时间: |
|
| 查看次数: |
766 次 |
| 最近记录: |