1.2.3. Kamelet Binding でのソースおよびシンクコンポーネントの接続

手順

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 および設定パラメーターを指定します。

     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-source Kamelet を log-sink Kamelet に接続するため、名前は coffee-to-log になります。

        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 ファイル内に定義されます。または、Configuring Kamelet instance parameters で説明されているように、プロパティーファイル、ConfigMap、または Secret に 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. シング 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 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 をクリックします。

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

        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