第 4 章 实现 AMQ 到 REST API 示例集成
此示例集成连接到 Red Hat AMQ 代理,以获取假设企业的项目交付记录。然后,集成会执行在记录上运行的自定义步骤,以识别收到所损坏的项目。在简单的数据映射后,集成会连接到 REST API,以获取供应商损坏项目的联系信息。
其他样本集成使用内置于 Fuse Online 中的连接器和数据操作。这种集成还这样做,但另外,它还提供了通过以下过程自定义和扩展 Fuse Online 的说明:
- 通过上传扩展名来添加自定义数据操作。
- 通过上传 OpenAPI 文档来添加自定义 REST API 客户端连接器。
Fuse Online 提供扩展文件和 OpenAPI 文档。
先决条件
- 您必须登录 Fuse Online。
- 您在在 OpenShift Container Platform 项目中运行的 Fuse Online 环境中工作,管理员添加了 Fuse Online 示例数据,其提供示例 PostgresDB 连接、AMQ Broker 和 To Do 应用,以确认集成可以正常工作。
要实现 AMQ 到 REST API 示例集成,主要步骤包括:
4.1. 创建 AMQ 连接 复制链接链接已复制到粘贴板!
复制链接链接已复制到粘贴板!
AMQ 到 REST API 示例集成首先连接到 OpenShift 项目中提供的 AMQ 代理(Red Hat AMQ)。在开始创建集成本身前,您必须启动代理并创建与该代理的连接。
流程
验证代理是否已启动:
- 在一个浏览器中,进入 OpenShift Web 控制台。
- 在控制台中,单击 Project。
- 在 Overview 页面上的 Inventory 部分中,单击 Services。
-
单击 broker-amq-tcp,然后单击 Pods。pod 的状态应该是
Running。
创建 AMQ 连接:
- 在 Fuse Online 中,在左侧面板中,单击 Connections 以显示任何可用的连接。
- 单击 Create Connection 以显示 Fuse Online 连接器。
- 点击 Red Hat AMQ 连接器。
输入以下内容来配置连接:
-
在 Broker URL 字段中,输入
tcp://broker-amq-tcp:61616作为从中获取数据的位置。 -
在 User name 字段中,输入
amq作为访问此 AMQ 代理的帐户的用户名。 -
在 Password 字段中,输入
topSecret作为访问此 AMQ 代理的帐户的密码。 - 将其他字段留空。
-
在 Broker URL 字段中,输入
- 单击 Validate。Fuse Online 立即尝试验证连接并显示一条消息,指示验证是否成功。如果验证失败,请检查您输入的值并重试。
- 验证成功后,单击 下一步。
-
在 Name 字段中输入您的选择的名称,帮助您将这个连接与任何其他连接区分开来。例如,输入
Red Hat AMQ Broker 1。 -
在 Description 字段中输入任何有助于了解这个连接的信息。例如,输入
连接提供的 Red Hat AMQ 消息代理。 - 点 Save 以查看您创建的连接现在可用。如果您输入了示例名称,您会看到 Red Hat AMQ Broker 1 现已可用。