9

我一直在通过this tutorial张贴由亚马逊。在标题为“启用lambda蓝图”的步骤中,它引用了dynamodb-to-elasticsearch蓝图。在我的AWS控制台中,没有这样的蓝图。有人知道这个蓝图的Python代码是什么样的吗?我是否因为我的特定AWS账户而无法看到此消息,或者AWS是否已将其删除?如何使用Lambda从DynamoDB写入ElasticSearch?

+0

也许他们现在更喜欢这种方式:http://docs.aws.amazon.com/elasticsearch-service/latest/developerguide/es-aws-integrations.html#es-aws-integrations-dynamodb-es – at0mzk

+0

我试过在进入lambda方法之前,但它导致我[这条路径](https://github.com/awslabs/logstash-input-dynamodb/issues/21),似乎并没有出现很棒的解决 –

回答

1

您需要确保您的表上启用了DynamoDB流,包括旧图像和新图像。首先,将DynamoDB流记录从Kinesis流记录中提取出来。然后,确定DynamoDB流记录是否表示插入,更新或删除。第三,正确委托并插入ES中的相应文档以进行插入和更新,并删除ES中的相应文档以进行删除。

暂时,您可以修改Github上的Python lambda handler shared here - 它解析流记录并将文档写入ES。