当前位置: 首页 > 知识库问答 >
问题:

将DynamoDB记录推入Kinesis流,然后推入S3(仅使用AWS控制台)

曾嘉瑞
2023-03-14

我对Amazon Kinesis和Amazon DynamoDB非常陌生。我已经为我的RDS MySQL数据库和Dynamo DB数据购买了AWS服务。现在我想利用我的dynamo Db数据。

通过使用AWS控制台界面,我想定期、实时地将DynamoDB新插入的记录推送到S3。我已经阅读了有关动觉的内容,但我不知道如何在不使用应用程序开发的情况下安排此管道。如果可能的话,Kindle引导我通过。非常感谢。

编辑我读到了关于Kinesis Firehose的文章,想知道dynamoDB是否可以发布到AWS Kinesis Firehose?

共有1个答案

洪楚
2023-03-14

要通过控制台完成所有这些,我建议您使用DynamoDB Streams(不同于Kenisis Streams)和Lambda。这篇博客文章描述了这个过程的aAWS公告。

高级步骤包括:

  1. 为您的表打开DynamoDB Streams。此步骤为您的所有项目更改定义生产者。
  2. 编写将成为消费者的lambda函数。您提到的只是您想要新插入的记录。本文指导您使用AWS控制台在Lambda中开发一个简单的Hello World。这是一个很好的起点。一旦您感到自信,请重新访问公告并按照那里的步骤使用DynamoDB流。
  3. 创建一些S3存储桶并将逻辑附加到lambda函数以将新项目数据存储到S3。

这是一个强大的过程,它模拟了传统的关系数据库触发器,但适用于DynamoDB中的NoSQL表。全部来自AWS控制台。

 类似资料:
  • 我正在尝试将一条记录从AWS Lambda函数推送到AWS DynamoDB。我可以使用AWSAPI成功地从我的pc上推送一条记录,但是当我将代码部署到AWS时,我就卡住了。 下面是可以从我的电脑成功推送记录的示例代码: 以及DynamoDB中的结果:来自DynamoDB控制台的屏幕截图 下面是我试图部署到Lambda的代码: 问题是,当Lambda函数运行时,DynamoDB中没有任何记录。以下

  • 英文原文:http://emberjs.com/guides/models/pushing-records-into-the-store/ 仓库可以认为是所有应用加载的记录的一个缓存池。如果应用中的控制器或者路由请求一个记录,当记录已经被缓存时,仓库会立即将其返回。否则仓库必须请求适配器去加载这个记录,这通常就意味着需要通过网络去服务器端去获取该记录。 为了避免一直等待着应用获取记录,可以事先将记

  • 我试图捕获DynamoDB表更改使用DynamoDB流和AWS提供JavaDynamoDB流Kinesis适配器。我正在Scala应用程序中使用AWSJavaSDK。 我从遵循AWS指南和通过AWS发布的代码示例开始。然而,我在让亚马逊自己发布的代码在我的环境中工作方面遇到了问题。我的问题在于对象。 在示例代码中,使用DynamoDB提供的流ARN配置了。 我在Scala应用程序中遵循了类似的模式

  • 您可以将记录推送到商店的缓存中,而无需从应用程序请求记录。 如果记录在缓存中,只有当路由或控制器询问时,商店才能返回记录。 例子 (Example) 下面给出的示例显示了将记录推送到余烬火基中。 使用以下代码打开在app/templates/下创建的application.hbs文件 - <h2>Pushing Record into Store</h2> <form> {{input ty

  • 我在互联网上尝试了所有可能的解决方案,但毫无希望 我想做的是简单地使用aws lambda函数(通过aws控制台)从DynamoDB(未包含在问题中)获取用户fcm令牌,使用该令牌创建endpoint Arn,将推送发送到该特定设备 我测试了使用SNS控制台发送,推送成功到达设备,但我未能使用Lambda函数将其发送到设备,尽管它提供了成功状态和消息ID 这是我使用的代码

  • 从这个问题开始,AWS DynamoDB流进入红移 DynamoDB-- 如何配置我的Kinesis函数以获取Lambda函数源? 我创建了一个DynamoDB表(购销),并添加了DynamoDB流。然后,我配置Lambda函数来拾取DynamoDB流。我的问题是如何配置Kinesis以获取Lambda函数源?我知道如何配置Lambda转换,不过我想把它作为源代码。不确定如何配置下面的直接输入源。