第 5 章 将 AMQ 实现到 REST API 示例集成

这个示例集成连接到 Red Hat AMQ 代理，以获取预测企业的项目交付记录。然后，集成会执行一个在记录上运行的自定义步骤，以识别在收到时损坏的任何项目。在简单的数据映射后，集成连接到 REST API，以获取损坏项目的厂商的联系信息。

其他示例集成使用内置在 Fuse Online 中的连接器和数据操作。这个集成还这样做，但它提供了自定义和扩展 Fuse Online 的说明，它通过引导您完成以下操作过程来定制和扩展 Fuse Online：

  • 通过上传扩展来添加自定义数据操作。
  • 通过上传 OpenAPI 文档来添加自定义 REST API 客户端连接器。

Fuse Online 提供扩展文件和 OpenAPI 文档。

先决条件

  • 您必须登录 Fuse Online。如果您还没有登录，请查看 您首次使用 Fuse Online 的时间。
  • 您在在 OpenShift Dedicated 上运行的 Fuse Online 评估环境中工作，或者在在管理员添加 Fuse Online 示例数据的 Fuse Online 环境中运行的 Fuse Online 环境工作，该环境提供了 To Do 应用来确认集成是否按预期工作。

要实现 AMQ 到 REST API 示例集成，主要步骤为：

  1. 第 5.1 节 “创建 AMQ 连接”
  2. 第 5.2 节 “使自定义步骤可用”
  3. 第 5.3 节 “创建 REST API 连接器”
  4. 第 5.4 节 “上传 To Do app 图标”
  5. 第 5.5 节 “创建 REST API 连接”
  6. 第 5.6 节 “创建并部署 AMQ 到 REST API 示例集成”
  7. 第 5.7 节 “确认 AMQ 到 REST API 集成是否正常工作”
  8. 第 5.8 节 “清理您的集成”

5.1. 创建 AMQ 连接

AMQ 到 REST API 示例集成首先连接到 OpenShift 项目中提供的 AMQ 代理(Red Hat AMQ)。在开始创建集成本身前，您必须启动代理并创建与该代理的连接。

流程

  1. 验证代理是否已启动：

    1. 在浏览器中，访问您的 OpenShift Web 控制台。
    2. 在控制台中，单击 Project。
    3. 在 Overview 页面上的 Inventory 部分，单击 Services。
    4. 点 broker-amq-tcp，然后点 Pods。容器集的状态应当是 Running。

  2. 创建 AMQ 连接：

    1. 在 Fuse Online 中，在左侧面板中，单击 Connections 以显示任何可用连接。
    2. 单击 Create Connection 以显示 Fuse Online 连接器。
    3. 点 Red Hat AMQ 连接器。

    4. 使用以下命令配置连接：

      1. 在 Broker URL 字段中，输入 tcp://broker-amq-tcp:61616 作为从中获取数据的位置。
      2. 在 User name 字段中，输入 amq 作为访问此 AMQ 代理的帐户的用户名。
      3. 在 Password 字段中，输入 topSecret 作为访问此 AMQ 代理的帐户的密码。
      4. 其他字段留空。
    5. 单击 Validate。Fuse Online 立即尝试验证连接并显示一条消息，指示验证是否成功。如果验证失败，请检查您输入的值并重试。
    6. 验证成功后，单击 Next。
    7. 在 Name 字段中输入您选择的名称，可帮助您将这个连接与任何其他连接区分开来。例如，输入 Red Hat AMQ Broker 1。
    8. 在 Description 字段中，输入有助于了解此连接的任何信息。例如，输入 Connection to the provided Red Hat AMQ 消息代理。
    9. 点 Save 查看您创建的连接现在可用。如果您输入了示例名称，您会看到 Red Hat AMQ Broker 1 现已正式发布。