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 セクションの上に integration セクションを追加し、(predicate-filter-action kamelet で必要とされるように) 以下の Builder トレイト設定プロパティーを指定します。

   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. KameletBinding リソースを更新します。

   oc apply -f coffee-to-log.yaml

   Camel K Operator は、更新された KameletBinding リソースを基に生成する Camel K インテグレーションを再生成し、実行します。

6. kamelet binding のステータスを表示するには、次のコマンドを実行します。

   oc get kameletbindings

7. 対応するインテグレーションのステータスを表示するには、次のコマンドを実行します。

   oc get integrations

8. ログファイルの出力を表示するには、以下を実行します。

   1. インテグレーションの Pod 名を取得します。

      oc get pods

   2. インテグレーションの Pod のログを表示します。

      oc logs <podname of the integration>

      たとえば、Pod 名が example-7885bdb9-84ht8 の場合、以下のコマンドを実行します。

      oc logs example-7885bdb9-84ht8

9. インテグレーションを停止するには、kamelet バインディングを削除します。

   oc delete kameletbindings/<kameletbinding-name>

   以下に例を示します。

   oc delete kameletbindings/coffee-to-log