16.2. 订阅 Knative 频道以获取信息

要在收到 Knative 频道消息时触发集成执行,请将 Knative 连接添加为简单集成的启动连接。当没有从频道接收消息达到指定分钟数时,启动这种方法的集成会自动缩减到 0 个 pod。默认值为 1 分钟。

这种自动扩展会节省资源,与简单集成相比,它与其他类型的连接(如连接到 AMQ 代理)相比具有优势。

先决条件

  • 启用到 Knative 资源的连接。
  • 要从中获取消息的 Knative 资源与 Fuse Online 位于同一集群中
  • 您知道您要从中获取信息的 Knative 频道的名称。

流程

  1. 在 Fuse Online 的左侧面板中,单击 Integrations
  2. Create Integration
  3. Choose a connection 页面中,点 Knative 连接。
  4. 选择 Receive from Channel 操作。
  5. Channel name 字段显示可用 Knative 频道列表。
  6. 选择您要获取信息的资源的 Knative 频道名称。
  7. Next 指定 Receive from Channel 操作的输出类型。这是连接传递给集成中下一步的类型。

    1. Select Type 字段中,如果不需要知道数据类型,则接受 类型规格, 然后点 Next。您不需要遵循这些指令的其余部分。

      但是,建议使用结构化的数据类型。例如,如果要在数据映射映射映射器步骤中的连接输出,您必须指定数据类型。数据映射器无法显示非结构化数据的字段。

      要指定数据类型,点 Select Type 字段,并选择以下之一作为 schema 类型:

      • JSON 模式是 描述 JSON 数据结构的文档。文档的介质类型是 application/schema+json
      • JSON 实例 是包含 JSON 数据的文档。文档的介质类型是 application/json
      • XML 模式 是一个描述 XML 数据结构的文档。文档的文件扩展为 .xsd
      • XML 实例 是包含 XML 数据的文档。文档的文件扩展为 .xml
    2. Definition 输入框中,粘贴符合您选择的 schema 类型的定义。例如,如果您选择 JSON 模式,您将粘贴 JSON 模式文件的内容,该文件的介质类型为 application/schema+json
    3. Data Type Name 字段中输入您为数据类型选择的名称。例如,如果您要为供应商指定 JSON 模式,您可以指定 Vendor 作为数据类型名称。

      在创建或编辑使用指定此类型的连接时,您将看到此数据类型名称。Fuse Online 在集成视觉化和数据映射程序中显示类型名称。

    4. Data Type Description 字段中,提供可帮助您区分此类型的信息。当您将鼠标悬停在处理此类型的步骤上时,此描述会出现在数据映射程序中。
    5. 点击 Next

结果

Fuse Online 会提示您添加简单集成的完成连接。

在执行过程中,当所选 Knative 频道收到新消息时,Knative 连接会将信息传递给集成中的下一步,

后续步骤

将所有需要的连接添加到集成。然后,在启动集成的 Knative 连接后添加数据映射程序步骤。将 source message 字段映射到下一个连接中的 target 字段。