第 5 章 将 AMQ 实现到 REST API 示例集成
这个示例集成连接到 Red Hat AMQ 代理,以获取预测企业的项目交付记录。然后,集成会执行一个在记录上运行的自定义步骤,以识别在收到时损坏的任何项目。在简单的数据映射后,集成连接到 REST API,以获取损坏项目的厂商的联系信息。
其他示例集成使用内置在 Fuse Online 中的连接器和数据操作。这个集成还这样做,但它提供了自定义和扩展 Fuse Online 的说明,它通过引导您完成以下操作过程来定制和扩展 Fuse Online:
- 通过上传扩展来添加自定义数据操作。
- 通过上传 OpenAPI (Swagger)文档来添加自定义 REST API 客户端连接器。
Fuse Online 提供扩展文件和 OpenAPI 文档。
先决条件
- 您必须登录 Fuse Online。如果您还没有登录,请查看 您首次使用 Fuse Online 的时间。
- 您在在 OpenShift Online 或 OpenShift Dedicated 上运行的 Fuse Online 评估环境中工作。或者,您在在 OpenShift Container Platform 项目中运行的 Fuse Online 环境,管理员添加了 Fuse Online 示例数据,它提供了 To Do 应用来确认集成是否按预期工作。
要实现 AMQ 到 REST API 示例集成,主要步骤为:
5.1. 创建 AMQ 连接 复制链接链接已复制到粘贴板!
复制链接链接已复制到粘贴板!
AMQ 到 REST API 示例集成首先连接到 OpenShift Online 项目中提供的 AMQ 代理(Red Hat AMQ)。在开始创建集成本身前,您必须启动代理并创建与该代理的连接。
流程
启动代理:
- 在浏览器中,前往 OpenShift Online Web 控制台。您的 Fuse Online 环境在 OpenShift Online 上运行。
在控制台中,在 My Projects 下,单击 Fuse Online 以显示项目概述。
项目的名称类似于
proj123456
。- 在概述中,点击第一个条目 broker-amq, #1 左侧的 > 来展开提供的 Red Hat AMQ 代理的条目。
- 在右侧,单击 up caret 以扩展为运行 1 个 pod。这将启动 AMQ 代理。
创建 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 立即尝试验证连接并显示一条消息,指示验证是否成功。如果验证失败,请检查您输入的值并重试。
- 验证成功后,单击 Next。
-
在 Name 字段中输入您选择的名称,可帮助您将这个连接与任何其他连接区分开来。例如,输入
Red Hat AMQ Broker 1
。 -
在 Description 字段中,输入有助于了解此连接的任何信息。例如,输入
Connection to the provided Red Hat AMQ 消息代理。
- 点 Save 查看您创建的连接现在可用。如果您输入了示例名称,您会看到 Red Hat AMQ Broker 1 现已正式发布。