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 섹션 위에 통합 섹션을 추가하고 predicate-filter-action Kamelet에서 요구하는 대로 다음 Builder trait configuration 속성을 제공합니다.

   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 섹션을 추가하고 작업 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는 업데이트된 KameletBinding 리소스를 기반으로 생성하는 CamelK 통합을 다시 생성하고 실행합니다.

6. Kamelet Binding의 상태를 보려면 다음을 수행합니다.

   oc get kameletbindings

7. 해당 통합의 상태를 확인하려면 다음을 수행합니다.

   oc get integrations

8. 통합 로그 파일 출력을 보려면 다음을 수행합니다.

   kamel logs <integration-name>

   예를 들어 통합 이름이 coffee-to-log 인 경우 다음을 수행합니다.

   Kamel 로그 coffee-to-log

9. 통합을 중지하려면 Kamelet Binding을 삭제합니다.

   oc delete kameletbindings/<kameletbinding-name>

   예를 들면 다음과 같습니다.

   oc delete kameletbindings/coffee-to-log