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. 以下のサブスクリプション設定を選択します。

   • Update Channel > 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 - Command Line Interface セクションまでスクロールダウンします。
   3. ローカルのオペレーティングシステム (Linux、Mac、Windows) のバイナリーをダウンロードするためのリンクをクリックします。
   4. CLI を展開してシステムパスにインストールします。

   5. Kamel K CLI にアクセスできることを確認するには、コマンドウィンドウを開き、以下のコマンドを入力します。

      kamel --help

      このコマンドは、Camel K CLI コマンドに関する情報を表示します。

1. ターミナルウィンドウで、OpenShift クラスターにログインします。

2. 利用可能な Kamelets の一覧を表示する方法は、Camel K Operator のインストール方法（特定の namespace またはクラスターモード）によって異なります。

   • Camel K Operator がクラスターモードでインストールされている場合は、以下のコマンドを使用して、利用可能な Kamelets を表示します。

     oc get kamelet -n openshift-operators

   • Camel K Operator が特定の namespace にインストールされている場合は、以下を行います。

     1. Camel K Operator がインストールされているプロジェクトを開きます。

        oc project <camelk-project>

        たとえば、Camel K Operator が my-camel-k-project プロジェクトにインストールされている場合は、以下のようになります。

        oc project my-camel-k-project

     2. 以下のコマンドを実行します。

        oc get kamelets

手順

1. OpenShift クラスターにログインします。

2. Camel K Operator がインストールされている作業プロジェクトを開きます。Camel K Operator を cluster-mode でインストールした場合、クラスター上の任意のプロジェクトで利用できます。

   たとえば、my-camel-k-project という名前の既存のプロジェクトを開くには、以下のコマンドを実行します。

   oc project my-camel-k-project

3. 以下のオプションのいずれかを使用して、新しい Kamelet Bindingを作成します。

   • kamel bind コマンドを使用して Kamelet Binding を作成し、実行します（このオプションは、コマンドライン定義の助けとなる単純な Kamelet Bindingに役に立ちます）

   • YAML ファイルを作成して Kamelet Bindingを定義し、oc apply コマンドを使用して実行します（このオプションは Kamelet Binding設定が複雑である場合に便利です）。

     kamel bind コマンドを使用した新しい Kamelet Bindingの作成

     以下の kamel bind 構文を使用して、ソースおよびシンク 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 Operator は KameletBinding リソースを生成し、対応する Camel K インテグレーションを実行します。

     YAML ファイルを使用した新しい Kamelet Bindingの作成

     1. 任意のエディターで、以下の構造で YAML ファイルを作成します。

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

     2. Kamelet Bindingの名前を追加します。

        この例では、バインディングが coffee-source Kamelet を log-sink Kamelet に接続するため、名前は coffee-to-log になります。

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

     3. ソース Kamelet (例: coffee-source) を指定し、Kamelet のパラメーターを設定します。

        注記：この例では、パラメーターは Kamelet Binding の YAML ファイル内に定義されます。または、「Kamelet インスタンスのパラメーターの設定」で説明されているように、プロパティーファイル、ConfigMap、または Secret に 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. シング 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 namespace に追加します (KameletBinding)。

        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 をクリックします。

        以下の例のようなコーヒーイベントの一覧が表示されるはずです。

        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 ファイルの内容になります。

   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 セクションを追加し、(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

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

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 セクションに追加します。

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

   たとえば、coffee-to-log Kamelet Bindingで、ログハンドラーを追加して、エラーがログファイルに送信される最大回数を指定します。

   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を編集して、ソースとシンク Kamelets の間の中間ステップとして topic-name-matches-filter-action Kamelet を追加します。

   通常、ソース Kamelet として kafka-source Kamelet を使用し、トピックを必要な topic パラメーターの値として指定します。

   以下の Kamelet Binding の例では、kafka-source Kamelet は test-topic、test-topic-2、および test-topic-3 Kafka トピックを指定し、topic-name-matches-filter-action Kamelet は、topic-test トピックからイベントデータをフィルターするように指定します。

   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 を使用して、Kamelet Bindingの topic-name-matches-filter-action ステップの前に Kafka トピックフィールドを中間ステップとして追加できます。

   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 ブローカー一覧