2.2. 连接到 Amazon DynamoDB
集成可以从 Amazon DynamoDB 表中检索数据,将数据添加到 DynamoDB 表中,或者从 DynamoDB 表中删除数据。为此,请创建一个 Amazon DynamoDB 连接,然后将该连接添加到集成流中。
详情请查看:
2.2.1. 创建 Amazon DynamoDB 连接
您必须创建一个 Amazon DynamoDB 连接,然后才能连接到集成中的 Amazon DynamoDB。
先决条件
- 您必须具有 AWS 访问密钥。有关创建到 Amazon 服务的连接,请参阅获取 AWS 凭证。
- 您必须知道哪些 AWS 区域包含您希望连接访问的 DynamoDB 表。
- 您必须知道希望连接访问的 DynamoDB 表的名称。当集成连接到 DynamoDB 时,此表必须存在。
流程
- 在 Fuse Online 中,在左侧面板中,单击 Connections 以显示任何可用连接。
- 单击 Create Connection 以显示 Fuse Online 连接器。
- 点 Amazon DynamoDB 连接器。
- 在 Access Key 字段中,输入 Amazon 访问密钥 ID,它是管理您希望连接访问的 DynamoDB 表的 AWS 帐户中的用户访问密钥 ID。
- 在 Secret Key 字段中,为您指定的 Amazon 访问密钥 ID 输入 Amazon secret 访问密钥。
- 在 Region 字段中,选择 DynamoDB 表所在的 AWS 区域。
- 在 Table Name 字段中,输入您希望此连接访问的 DynamoDB 表的名称。
- 单击 Validate。Fuse Online 立即尝试验证连接并显示一条消息,指示验证是否成功。如果验证失败,请根据需要重新传输配置详情,然后重试。
- 验证成功后,单击 Next。
-
在 Name 字段中输入您选择的名称,可帮助您将这个连接与任何其他连接区分开来。例如,输入
DynamoDB West
。 -
在 Description 字段中,输入有助于了解此连接的任何信息。例如,输入
Sample DynamoDB 连接,以访问 western 区域中的销售数据。
- 点 Save 查看您创建的连接现在可用。如果您输入了示例名称,您会看到 DynamoDB West 显示为一个连接,您可以选择添加到集成。
结果
当 Fuse Online 提示您添加到集成时,它会显示您刚才创建的 DynamoDB 连接。此连接始终,仅访问您在创建连接时指定的 DynamoDB 表。
2.2.2. 从 Amazon DynamoDB 表中获取数据
在集成流中,若要从 Amazon DynamoDB 表中获取项目,请将 Amazon DynamoDB 连接添加到流中间。
DynamoDB 连接无法启动简单的集成。如果要定期从 DynamoDB 表中获取数据,请启动与计时器的简单集成,后跟一个查询表的 DynamoDB 连接。
先决条件
- 您创建了 Amazon DynamoDB 连接。
- 您正在创建或编辑流,Fuse Online 会提示您添加到集成。
流程
- 在流视觉化中,点您要添加 Amazon DynamoDB 连接的加号。
- 在 Choose a connection 页面上,单击 Amazon DynamoDB 连接,该连接配置为访问您要从中获取数据的表。
- 在 Choose an action 页面上,选择 Query 操作。
在 Filter 字段中,指定 JSON 表示法来标识连接应返回的项目的键属性。您可以使用
:#
指定输入参数。例如,要获取具有两个关键属性的项目,规格可能类似如下:{"key1":":#PARAM1", "key2":":#PARAM2"}
可选的。在 Attributes to query 字段中,输入以逗号分隔的属性名称列表,其中包含您要返回的数据。例如:
key1,key2,attribute3,attribute4,attribute5
如果没有指定属性,查询会返回 key 属性。
- 点击 Next。
结果
集成现在有一个 DynamoDB 连接,用于获取数据。在运行时,连接会返回包含查询结果的 JSON 实例文档。
后续步骤
如果您在 Filter 字段中指定了占位符参数,请在此连接前添加数据映射程序步骤。在数据映射程序步骤中,将 source 字段映射到 DynamoDB 连接中的目标占位符字段。
2.2.3. 将数据添加到 Amazon DynamoDB 表中
在流中,或完成简单集成,DynamoDB 连接可以将项目添加到 DynamoDB 表中。为此,请在流的中间或简单集成完成连接中添加 DynamoDB 连接。
在本发行版本中,DynamoDB 连接无法更新 DynamoDB 表中的项目。以后的发行版本中应该会改变。
先决条件
- 您创建了 Amazon DynamoDB 连接。
- 您正在创建或编辑简单集成,Fuse Online 会提示您添加到集成或选择完成连接。
流程
- 在 Choose a connection 页面上,单击配置为访问您要添加到的表的 Amazon DynamoDB 连接。
- 在 Choose an action 页面上,选择 Put Item。
在 element 字段的 JSON 定义中,输入 JSON 表示法来定义要添加的表项。您必须指定项目的 key 属性。允许输入参数占位符,前缀为
:
4.1。确保指定您要存储的所有属性/值。在以下示例中,userID
是密钥:{"userID":"aslan","attr1":"some-value","attr2":"another-value"}
- 点击 Next。
结果
连接会出现在您添加它的位置的集成视觉化中。在执行期间,连接会将定义的 JSON 项添加到连接配置为访问的 DynamoDB 表中。
后续步骤
如果您在项目的 JSON 定义中指定占位符参数,请在此连接前添加数据映射程序步骤。在数据映射程序步骤中,将 source 字段映射到 DynamoDB 连接中的目标占位符字段。
2.2.4. 从 Amazon DynamoDB 表中删除数据
在流的中间或完成简单集成,DynamoDB 连接可以从 DynamoDB 表中删除项目。为此,请在流的中间或简单集成完成连接中添加 DynamoDB 连接。
先决条件
- 您创建了 Amazon DynamoDB 连接。
- 您正在创建或编辑简单集成,Fuse Online 会提示您添加到集成或选择完成连接。
流程
- 在 Choose a connection 页面上,单击 Amazon DynamoDB 连接,该连接配置为访问包含您要删除的项目的表。
- 在 Choose an action 页面上,选择 Remove Item。
在 element 字段的 JSON 过滤器 中,输入 JSON 表示法来标识您要删除的项目。您必须指定项目的 key 属性。允许使用前缀
:#
的输入参数。在以下示例中,userID
是一个关键属性:{"userID":"aslan"}
- 点击 Next。
结果
连接会出现在您添加它的流视觉化中。
后续步骤
如果您在 element 字段的 JSON 过滤器 中指定占位符参数,请在此连接前添加数据映射程序步骤。在数据映射程序步骤中,将 source 字段映射到 DynamoDB 连接中的每个目标占位符字段。