2

是否有任何 AWS 托管解决方案允许使用 DynamoDB 作为源和 Lambda 函数作为接收器来执行本质上是数据迁移的操作?

我正在设置一个 Lambda 来处理 DynamoDB 流,并且我希望能够使用相同的 Lambda 来处理所有现有项目,而不必在 AWS Glue 的 Spark 或 Hive 作业中重写相同的逻辑、数据管道或批处理。(我可以接受 Lambda 的输入不同于 DynamoDB 流记录——我可以在我的 Lambda 中处理它——我只是想避免在其他地方重新实现我的业务逻辑。)

我知道我可以建立自己的设置来运行全表扫描,但我也在努力避免任何无差别的繁重工作。

编辑:一种可能性是更新 DynamoDB 中的所有项目,以便触发 DynamoDB Stream 事件。但是,我的问题仍然存在 — 是否有 AWS 托管服务可以为我做到这一点?

4

1 回答 1

1

您可以创建新的 kinesis 数据流。将此作为触发器添加到您现有的 lambda 函数中。创建一个新的简单 lambda 函数,它扫描整个表并将记录放入此流中。而已。

您的业​​务逻辑保留在您的原始功能中。您正在通过 kinesis 将现有数据从 dynamodb 发送到此函数。

参考:https ://aws.amazon.com/blogs/compute/indexing-amazon-dynamodb-content-with-amazon-elasticsearch-service-using-aws-lambda/

于 2019-04-06T20:53:04.217 回答