1.2.3. 在 Kamelet Binding 中连接源和接收器组件

流程

1. 登录到您的 OpenShift 集群。

2. 打开安装 Camel K operator 的工作项目。如果您以 cluster-mode 安装 Camel K operator，它将可供集群上的任何项目使用。

   例如，要打开名为 my-camel-k-project 的现有项目：

   oc project my-camel-k-project

3. 使用以下选项之一创建新的 Kamelet Binding：

   • 使用 kamel bind 命令创建并运行 Kamelet Binding （这对于命令行定义相关的简单 Kamelet Bindings 很有用）

   • 创建一个 YAML 文件来定义 Kamelet Binding，然后使用 oc apply 命令来运行它（当 Kamelet Binding 配置更为复杂时，此选项很有用）。

     使用 kamel bind 命令创建一个新的 Kamelet Binding

     使用以下 kamel bind 语法指定 source 和 sink Kamelets 和任何配置参数：

     kamel bind <kamelet-source> -p “<property>=<property-value>” <kamelet-sink> -p “<property>=<property-value>”

     例如：

     kamel bind coffee-source -p “source.period=5000” log-sink -p "sink.showStreams=true"

     Camel K 操作器生成 KameletBinding 资源并运行对应的 Camel K 集成。

     使用 YAML 文件创建一个新的 Kamelet Binding

     1. 在您选择的编辑器中，创建具有以下结构的 YAML 文件：

        apiVersion: camel.apache.org/v1alpha1
        kind: KameletBinding
        metadata:
          name:
        spec:
          source:
          sink:

     2. 为 Kamelet Binding 添加名称。

        在本例中，名称为 coffee-to-log，因为绑定将 coffee-source Kamelet 连接到 log-sink Kamelet。

        apiVersion: camel.apache.org/v1alpha1
        kind: KameletBinding
        metadata:
          name: coffee-to-log
        spec:
          source:
          sink:

     3. 指定 source Kamelet （如 coffee-source）并为 Kamelet 配置任何参数。

        注： 在本例中，参数在 Kamelet Binding 的 YAML 文件中定义。另外，您还可以在属性文件、ConfigMap 或 Secret 中配置 Kamelet 的参数，如 配置 Kamelet 实例参数 中所述。

        apiVersion: camel.apache.org/v1alpha1
        kind: KameletBinding
        metadata:
          name: coffee-to-log
        spec:
          source:
            ref
              kind: Kamelet
              apiVersion: camel.apache.org/v1alpha1
              name: coffee-source
            properties:
              period: 5000
          sink:

     4. 指定 sink Kamelet （如 log-sink），并为 Kamelet 配置任何参数。使用 log-sink Kamelet 的可选 showStreams 参数来显示消息正文。

        apiVersion: camel.apache.org/v1alpha1
        kind: KameletBinding
        metadata:
          name: coffee-to-log
        spec:
          source:
            ref:
              kind: Kamelet
              apiVersion: camel.apache.org/v1alpha1
              name: coffee-source
            properties:
              period: 5000
          sink:
            ref:
              kind: Kamelet
              apiVersion: camel.apache.org/v1alpha1
              name: log-sink
            properties:
              showStreams: true

     5. 保存 YAML 文件（例如 coffee-to-log.yaml）。

     6. 将 KameletBinding 作为资源添加到 OpenShift 命名空间中：

        oc apply -f <kamelet-binding>.yaml

        例如：

        oc apply -f coffee-to-log.yaml

        Camel K operator 使用 KameletBinding 资源生成并运行 Camel K 集成。

4. 查看 Kamelet Binding 的状态：

   oc get kameletbindings

5. 查看对应的集成状态： oc get integrations

6. 查看输出：

   • 要从命令行查看日志，请打开终端窗口，然后输入以下命令：

     kamel log <integration-name>

     例如，如果集成名称为 coffee-to-log，请使用以下命令：

     kamel log coffee-to-log

   • 查看 OpenShift Web 控制台中的日志：

     1. 选择 Workloads > Pods。

     2. 单击 Camel K integration's pod 的名称，然后单击 Logs。

        您应该看到类似以下示例的 coffee 事件列表：

        INFO  [log-sink-E80C5C904418150-0000000000000001] (Camel (camel-1) thread #0 - timer://tick) {"id":7259,"uid":"a4ecb7c2-05b8-4a49-b0d2-d1e8db5bc5e2","blend_name":"Postmodern Symphony","origin":"Huila, Colombia","variety":"Kona","notes":"delicate, chewy, black currant, red apple, star fruit","intensifier":"balanced"}

7. 要停止集成，请删除 Kamelet Binding：

   oc delete kameletbindings/<kameletbinding-name>

   例如：

   oc delete kameletbindings/coffee-to-log