3.3. Kamelet Binding でのデータソースの Knative 宛先への接続

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

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

Kamelet Binding の名前を追加します。この例では、バインディングが coffee-source Kamelet を Knative 宛先に接続するため、名前は coffees-to-knative になります。

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

Kamelet Binding のソースの場合は、データソース Kamelet を指定し (たとえば、coffee-source Kamelet はコーヒーに関するデータが含まれるイベントを生成します)、Kamelet のパラメーターを設定します。

apiVersion: camel.apache.org/v1alpha1
kind: KameletBinding
metadata:
  name: coffees-to-knative
spec:
  source:
    ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: coffee-source
    properties:
      period: 5000
  sink:

Kamelet Binding のシンクでは、Knative チャネルまたはブローカーおよび必要なパラメーターを指定します。

以下の例では、Knative チャネルをシンクとして指定します。

apiVersion: camel.apache.org/v1alpha1
kind: KameletBinding
metadata:
  name: coffees-to-knative
spec:
  source:
    ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: coffee-source
    properties:
      period: 5000
  sink:
    ref:
      apiVersion: messaging.knative.dev/v1
      kind: InMemoryChannel
      name: mychannel

この例では、Knative ブローカーをシンクとして指定します。

apiVersion: camel.apache.org/v1alpha1
kind: KameletBinding
metadata:
  name: coffees-to-knative
spec:
  source:
    ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: coffee-source
    properties:
      period: 5000
  sink:
      ref:
        kind: Broker
        apiVersion: eventing.knative.dev/v1
        name: default
      properties:
        type: coffee

Kamelet Binding をリソースとして OpenShift namespace に追加します。

oc apply -f <kamelet binding filename>

以下に例を示します。

oc apply -f coffees-to-knative.yaml

Camel K Operator は、KameletBinding リソースを使用して Camel K インテグレーションを生成し、実行します。ビルドに数分かかる場合があります。

KameletBinding のステータスを表示するには、以下を実行します。

oc get kameletbindings

インテグレーションの状態を表示するには、以下を実行します。

oc get integrations

インテグレーションのログを表示するには、以下を実行します。

kamel logs <integration> -n <project>

以下に例を示します。

kamel logs coffees-to-knative -n my-camel-knative