2.2. 连接到 Amazon DynamoDB


集成可以从 Amazon DynamoDB 表中检索数据,将数据添加到 DynamoDB 表中,或者从 DynamoDB 表中删除数据。为此,请创建一个 Amazon DynamoDB 连接,然后将该连接添加到集成流中。

详情请查看:

2.2.1. 创建 Amazon DynamoDB 连接

您必须创建一个 Amazon DynamoDB 连接,然后才能连接到集成中的 Amazon DynamoDB。

先决条件

流程

  1. 在 Fuse Online 中,在左侧面板中,单击 Connections 以显示任何可用连接。
  2. 单击 Create Connection 以显示 Fuse Online 连接器。
  3. Amazon DynamoDB 连接器。
  4. Access Key 字段中,输入 Amazon 访问密钥 ID,它是管理您希望连接访问的 DynamoDB 表的 AWS 帐户中的用户访问密钥 ID。
  5. Secret Key 字段中,为您指定的 Amazon 访问密钥 ID 输入 Amazon secret 访问密钥。
  6. Region 字段中,选择 DynamoDB 表所在的 AWS 区域。
  7. Table Name 字段中,输入您希望此连接访问的 DynamoDB 表的名称。
  8. 单击 Validate。Fuse Online 立即尝试验证连接并显示一条消息,指示验证是否成功。如果验证失败,请根据需要重新传输配置详情,然后重试。
  9. 验证成功后,单击 Next
  10. Name 字段中输入您选择的名称,可帮助您将这个连接与任何其他连接区分开来。例如,输入 DynamoDB West
  11. Description 字段中,输入有助于了解此连接的任何信息。例如,输入 Sample DynamoDB 连接,以访问 western 区域中的销售数据。
  12. Save 查看您创建的连接现在可用。如果您输入了示例名称,您会看到 DynamoDB West 显示为一个连接,您可以选择添加到集成。

结果

当 Fuse Online 提示您添加到集成时,它会显示您刚才创建的 DynamoDB 连接。此连接始终,仅访问您在创建连接时指定的 DynamoDB 表。

2.2.2. 从 Amazon DynamoDB 表中获取数据

在集成流中,若要从 Amazon DynamoDB 表中获取项目,请将 Amazon DynamoDB 连接添加到流中间。

DynamoDB 连接无法启动简单的集成。如果要定期从 DynamoDB 表中获取数据,请启动与计时器的简单集成,后跟一个查询表的 DynamoDB 连接。

先决条件

  • 您创建了 Amazon DynamoDB 连接。
  • 您正在创建或编辑流,Fuse Online 会提示您添加到集成。

流程

  1. 在流视觉化中,点您要添加 Amazon DynamoDB 连接的加号。
  2. Choose a connection 页面上,单击 Amazon DynamoDB 连接,该连接配置为访问您要从中获取数据的表。
  3. Choose an action 页面上,选择 Query 操作。
  4. Filter 字段中,指定 JSON 表示法来标识连接应返回的项目的键属性。您可以使用 :# 指定输入参数。例如,要获取具有两个关键属性的项目,规格可能类似如下:

    {"key1":":#PARAM1", "key2":":#PARAM2"}
  5. 可选的。在 Attributes to query 字段中,输入以逗号分隔的属性名称列表,其中包含您要返回的数据。例如:

    key1,key2,attribute3,attribute4,attribute5

    如果没有指定属性,查询会返回 key 属性。

  6. 点击 Next

结果

集成现在有一个 DynamoDB 连接,用于获取数据。在运行时,连接会返回包含查询结果的 JSON 实例文档。

后续步骤

如果您在 Filter 字段中指定了占位符参数,请在此连接前添加数据映射程序步骤。在数据映射程序步骤中,将 source 字段映射到 DynamoDB 连接中的目标占位符字段。

2.2.3. 将数据添加到 Amazon DynamoDB 表中

在流中,或完成简单集成,DynamoDB 连接可以将项目添加到 DynamoDB 表中。为此,请在流的中间或简单集成完成连接中添加 DynamoDB 连接。

注意

在本发行版本中,DynamoDB 连接无法更新 DynamoDB 表中的项目。以后的发行版本中应该会改变。

先决条件

  • 您创建了 Amazon DynamoDB 连接。
  • 您正在创建或编辑简单集成,Fuse Online 会提示您添加到集成或选择完成连接。

流程

  1. Choose a connection 页面上,单击配置为访问您要添加到的表的 Amazon DynamoDB 连接。
  2. Choose an action 页面上,选择 Put Item
  3. element 字段的 JSON 定义中,输入 JSON 表示法来定义要添加的表项。您必须指定项目的 key 属性。允许输入参数占位符,前缀为 : 4.1。确保指定您要存储的所有属性/值。在以下示例中,userID 是密钥:

    {"userID":"aslan","attr1":"some-value","attr2":"another-value"}
  4. 点击 Next

结果

连接会出现在您添加它的位置的集成视觉化中。在执行期间,连接会将定义的 JSON 项添加到连接配置为访问的 DynamoDB 表中。

后续步骤

如果您在项目的 JSON 定义中指定占位符参数,请在此连接前添加数据映射程序步骤。在数据映射程序步骤中,将 source 字段映射到 DynamoDB 连接中的目标占位符字段。

2.2.4. 从 Amazon DynamoDB 表中删除数据

在流的中间或完成简单集成,DynamoDB 连接可以从 DynamoDB 表中删除项目。为此,请在流的中间或简单集成完成连接中添加 DynamoDB 连接。

先决条件

  • 您创建了 Amazon DynamoDB 连接。
  • 您正在创建或编辑简单集成,Fuse Online 会提示您添加到集成或选择完成连接。

流程

  1. Choose a connection 页面上,单击 Amazon DynamoDB 连接,该连接配置为访问包含您要删除的项目的表。
  2. Choose an action 页面上,选择 Remove Item
  3. element 字段的 JSON 过滤器 中,输入 JSON 表示法来标识您要删除的项目。您必须指定项目的 key 属性。允许使用前缀 :# 的输入参数。在以下示例中,userID 是一个关键属性:

    {"userID":"aslan"}
  4. 点击 Next

结果

连接会出现在您添加它的流视觉化中。

后续步骤

如果您在 element 字段的 JSON 过滤器 中指定占位符参数,请在此连接前添加数据映射程序步骤。在数据映射程序步骤中,将 source 字段映射到 DynamoDB 连接中的每个目标占位符字段。

Red Hat logoGithubRedditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

通过我们的产品和服务,以及可以信赖的内容,帮助红帽用户创新并实现他们的目标。

让开源更具包容性

红帽致力于替换我们的代码、文档和 Web 属性中存在问题的语言。欲了解更多详情,请参阅红帽博客.

關於紅帽

我们提供强化的解决方案,使企业能够更轻松地跨平台和环境(从核心数据中心到网络边缘)工作。

© 2024 Red Hat, Inc.