1.3. 将操作应用到连接中的数据

流程

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

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

   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

   Copy to Clipboard Toggle word wrap

2. 在 source 部分上方添加 集成 部分并提供以下 Builder 特征配置属性（根据 predicate-filter-action Kamelet 的要求）：

   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

   Copy to Clipboard Toggle word wrap

3. 在 source 和 sink 部分之间添加一个 steps 部分，并定义 action Kamelet。例如：

   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

   Copy to Clipboard Toggle word wrap
4. 保存您的更改。

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

   oc apply -f coffee-to-log.yaml

   Camel K operator re-generates 并运行它根据更新的 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