将应用程序与 Kamelets 集成

流程

1. 在 OpenShift Container Platform Web 控制台中，使用具有集群管理员权限的账户登录。

2. 创建新 OpenShift 项目：

   1. 在左侧导航菜单中，点击 Home > Project > Create Project。
   2. 输入项目名称，如 my-camel-k-project，然后单击 Create。
3. 在左侧导航菜单中，点 Operators > OperatorHub。
4. 在 Filter by keyword 文本框中，输入 Camel K，然后点 Red Hat Integration - Camel K Operator 卡。
5. 阅读 Operator 的信息，然后单击 Install。此时会打开 Operator 安装页面。

6. 选择以下订阅设置：

   • 更新频道 & gt; latest
   • Installation Mode > A specific namespace on the cluster > my-camel-k-project

   • Approval Strategy > Automatic

     注意

     如果您的环境需要，也可以使用 Installation mode > All namespaces on the cluster 和 Approval Strategy > Manual 设置。

7. 点 Install，然后等待几分钟，直到 Camel K Operator 准备就绪。

8. 下载并安装 Camel K CLI 工具：

   1. 在 OpenShift Web 控制台顶部的 Help 菜单(?)中选择 Command line tools。
   2. 向下滚动到 kamel - Red Hat Integration - Camel K - 命令行界面 部分。
   3. 单击链接，以下载本地操作系统的二进制文件(Linux、Mac、Windows)。
   4. 在您的系统路径中解压并安装 CLI。

   5. 要验证您可以访问 Kamel K CLI，请打开命令窗口，然后键入以下内容：

      kamel --help

      此命令显示有关 Camel K CLI 命令的信息。

1. 在终端窗口中，登录到您的 OpenShift 集群。

2. 查看可用的 Kamelets 列表取决于 Camel K operator 的安装方式（在特定命名空间或集群模式中）：

   • 如果在 cluster-mode 中安装 Camel K operator，使用以下命令查看可用的 Kamelets：

     oc get kamelet -n openshift-operators

   • 如果 Camel K operator 安装在特定命名空间中：

     1. 打开在其中安装 Camel K operator 的项目。

        oc project <camelk-project>

        例如，如果在 my-camel-k-project 项目中安装了 Camel K operator：

        oc project my-camel-k-project

     2. 运行以下命令：

        oc get kamelets

流程

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 绑定 语法指定 source 和 sink Kamelets 以及任何配置参数：

     Copy to Clipboard Toggle word wrap

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

     例如：

     Copy to Clipboard Toggle word wrap

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

     Camel K operator 生成 KameletBinding 资源并运行对应的 Camel K 集成。

     使用 YAML 文件创建新的 Kamelet Binding

     1. 在您选择的编辑器中，使用以下结构创建一个 YAML 文件：

        Copy to Clipboard Toggle word wrap

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

     2. 为 Kamelet Binding 添加名称。

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

        Copy to Clipboard Toggle word wrap

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

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

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

        Copy to Clipboard Toggle word wrap

        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 参数来显示消息正文。

        Copy to Clipboard Toggle word wrap

        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 集成 pod 的名称，然后单击 Logs。

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

        Copy to Clipboard Toggle word wrap

        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

流程

1. 在编辑器中打开 KameletBinding 文件。

   例如，以下是 coffee-to-log.yaml 文件的内容：

   Copy to Clipboard Toggle word wrap

   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

2. 在 source 部分添加一个 integration 部分，并提供以下 Builder 特征配置属性（如 predicate-filter-action Kamelet 要求）：

   Copy to Clipboard Toggle word wrap

   apiVersion: camel.apache.org/v1alpha1
   kind: KameletBinding
   metadata:
     name: coffee-to-log
   spec:
     integration:
            traits:
              builder:
                configuration:
                  properties:
                    - "quarkus.arc.unremovable- types=com.fasterxml.jackson.databind.ObjectMapper"
     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

3. 添加 steps 部分，在 source 和 sink 部分定义操作 Kamelet。例如：

   Copy to Clipboard Toggle word wrap

   apiVersion: camel.apache.org/v1alpha1
   kind: KameletBinding
   metadata:
     name: coffee-to-log
     spec:
       integration:
              traits:
                builder:
                  configuration:
                    properties:
                      - "quarkus.arc.unremovable-types=com.fasterxml.jackson.databind.ObjectMapper"
     source:
       ref:
         kind: Kamelet
         apiVersion: camel.apache.org/v1alpha1
         name: coffee-source
       properties:
         period: 5000
     steps:
     - ref:
         kind: Kamelet
         apiVersion: camel.apache.org/v1alpha1
         name: json-deserialize-action
     - ref:
         kind: Kamelet
         apiVersion: camel.apache.org/v1alpha1
         name: predicate-filter-action
       properties:
         expression: "@.intensifier =~ /.*deep/"
     - ref:
         kind: Kamelet
         apiVersion: camel.apache.org/v1alpha1
         name: json-serialize-action
     sink:
       ref:
         kind: Kamelet
         apiVersion: camel.apache.org/v1alpha1
         name: log-sink

4. 保存您的更改。

5. 使用 oc apply 命令更新 KameletBinding 资源，例如：

   oc apply -f coffee-to-log.yaml

   Camel K operator 会重新生成并运行基于更新的 KameletBinding 资源生成的 CamelK 集成。

6. 查看 Kamelet Binding 的状态：

   oc get kameletbindings

7. 查看其对应集成的状态：

   oc get integrations

8. 查看集成的日志文件输出：

   kamel logs <integration-name>

   例如，如果集成名称是 coffee-to-log ：

   kamel logs coffee-to-log

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

   oc delete kameletbindings/<kameletbinding-name>

   例如：

   oc delete kameletbindings/coffee-to-log

1. 在编辑器中打开 KameletBinding YAML 文件。

2. 在 sink 定义后，在 spec 部分添加一个 error handler 部分：

   Copy to Clipboard Toggle word wrap

   apiVersion: camel.apache.org/v1alpha1
   kind: KameletBinding
   metadata:
     name: example-kamelet-binding
   spec:
     source:
      ...
     sink:
      ...
     errorHandler: ...

   例如，在 coffee-to-log Kamelet Binding 中，通过添加日志错误处理程序来指定错误发送到日志文件的最大次数：

   Copy to Clipboard Toggle word wrap

   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
     errorHandler:
       log:
         parameters:
           maximumRedeliveries: 3

3. 保存您的文件。

流程

1. 编辑 Kamelet Binding，将 topic-name-matches-filter-action Kamelet 作为源和目标 Kamelets 之间的中间步骤包含。

   通常，您可以使用 kafka-source Kamelet 作为源 Kamelet，您提供了一个主题作为所需 主题 参数的值。

   在以下 Kamelet Binding 示例中，kafka-source Kamelet 指定 test-topic、test-topic-2 和 test-topic-3 Kafka 主题和 topic-name-matches-filter-action Kamelet 指定过滤出 topic-test 主题的事件数据：

   Copy to Clipboard Toggle word wrap

   apiVersion: camel.apache.org/v1alpha1
   kind: KameletBinding
   metadata:
     name: kafka-to-log-by-topic
   spec:
     source:
       ref:
         kind: Kamelet
         apiVersion: camel.apache.org/v1alpha1
         name: kafka-source
       properties:
         bootstrapServers: "broker.url:9092"
         password: "testpassword"
         topic: "test-topic, test-topic-2, test-topic-3"
         user: "testuser"
         securityProtocol: "PLAINTEXT" // only for AMQ streams
   steps:
     - ref:
         kind: Kamelet
         apiVersion: camel.apache.org/v1alpha1
         name: topic-name-matches-filter-action
       properties:
         regex:  "test-topic"
   sink:
       ref:
         kind: Kamelet
         apiVersion: camel.apache.org/v1alpha1
         name: log-sink
       properties:
           showStreams: true

   如果要过滤来自 kafka-source Kamelet 以外的源 Kamelet 的主题，您必须提供 Kafka 主题信息。您可以使用 insert-header-action Kamelet 将 Kafka 主题字段添加为中间步骤，在 Kamelet Binding 中的 topic-name-matches-filter-action 步骤前，如下例所示：

   Copy to Clipboard Toggle word wrap

   apiVersion: camel.apache.org/v1alpha1
   kind: KameletBinding
   metadata:
     name: coffee-to-log-by-topic
   spec:
     source:
       ref:
         kind: Kamelet
         apiVersion: camel.apache.org/v1alpha1
         name: coffee-source
       properties:
         period: 5000
   steps:
     - ref:
         kind: Kamelet
         apiVersion: camel.apache.org/v1alpha1
         name: insert-header-action
       properties:
         name:  "KAFKA.topic"
         value:  "test-topic"
     - ref:
         kind: Kamelet
         apiVersion: camel.apache.org/v1alpha1
         name: topic-name-matches-filter-action
       properties:
         regex:  "test-topic"
   sink:
       ref:
         kind: Kamelet
         apiVersion: camel.apache.org/v1alpha1
         name: log-sink
       properties:
         showStreams: true

2. 保存 Kamelet Binding YAML 文件。

流程

1. 登录您的 OpenShift 集群。

2. 打开您要在其中创建集成应用程序的项目。例如：

   oc project camel-k-knative

3. 使用 Knative (kn) CLI 命令创建频道

   kn channel create <channel_name> --type <channel_type>

   例如，要创建一个名为 mychannel 的频道：

   kn channel create mychannel --type messaging.knative.dev:v1:InMemoryChannel

4. 要确认频道现在存在，请输入以下命令列出所有现有频道：

   kn channel list

   您应该在列表中看到您的频道。

流程

1. 登录您的 OpenShift 集群。

2. 打开您要在其中创建集成应用程序的项目。例如：

   oc project camel-k-knative

3. 使用此 Knative (kn) CLI 命令创建代理：

   kn broker create default

4. 要确认代理现在存在，请输入以下命令列出所有现有代理：

   kn broker list