16.2. 订阅 Knative 频道以获取信息
要在收到 Knative 频道消息时触发集成执行,请将 Knative 连接添加为简单集成的启动连接。当没有从频道接收消息达到指定分钟数时,启动这种方法的集成会自动缩减到 0 个 pod。默认值为 1 分钟。
这种自动扩展会节省资源,与简单集成相比,它与其他类型的连接(如连接到 AMQ 代理)相比具有优势。
先决条件
- 启用到 Knative 资源的连接。
- 要从中获取消息的 Knative 资源与 Fuse Online 位于同一集群中
- 您知道您要从中获取信息的 Knative 频道的名称。
流程
- 在 Fuse Online 的左侧面板中,单击 Integrations。
- 点 Create Integration。
- 在 Choose a connection 页面中,点 Knative 连接。
- 选择 Receive from Channel 操作。
- 点 Channel name 字段显示可用 Knative 频道列表。
- 选择您要获取信息的资源的 Knative 频道名称。
点 Next 指定 Receive from Channel 操作的输出类型。这是连接传递给集成中下一步的类型。
在 Select Type 字段中,如果不需要知道数据类型,则接受 类型规格, 然后点 Next。您不需要遵循这些指令的其余部分。
但是,建议使用结构化的数据类型。例如,如果要在数据映射映射映射器步骤中的连接输出,您必须指定数据类型。数据映射器无法显示非结构化数据的字段。
要指定数据类型,点 Select Type 字段,并选择以下之一作为 schema 类型:
-
JSON 模式是 描述 JSON 数据结构的文档。文档的介质类型是
application/schema+json。 -
JSON 实例 是包含 JSON 数据的文档。文档的介质类型是
application/json。 -
XML 模式 是一个描述 XML 数据结构的文档。文档的文件扩展为
.xsd。 -
XML 实例 是包含 XML 数据的文档。文档的文件扩展为
.xml。
-
JSON 模式是 描述 JSON 数据结构的文档。文档的介质类型是
-
在 Definition 输入框中,粘贴符合您选择的 schema 类型的定义。例如,如果您选择 JSON 模式,您将粘贴 JSON 模式文件的内容,该文件的介质类型为
application/schema+json。 在 Data Type Name 字段中输入您为数据类型选择的名称。例如,如果您要为供应商指定 JSON 模式,您可以指定
Vendor作为数据类型名称。在创建或编辑使用指定此类型的连接时,您将看到此数据类型名称。Fuse Online 在集成视觉化和数据映射程序中显示类型名称。
- 在 Data Type Description 字段中,提供可帮助您区分此类型的信息。当您将鼠标悬停在处理此类型的步骤上时,此描述会出现在数据映射程序中。
- 点击 Next。
结果
Fuse Online 会提示您添加简单集成的完成连接。
在执行过程中,当所选 Knative 频道收到新消息时,Knative 连接会将信息传递给集成中的下一步,
后续步骤
将所有需要的连接添加到集成。然后,在启动集成的 Knative 连接后添加数据映射程序步骤。将 source message 字段映射到下一个连接中的 target 字段。