3.3. 在 Kamelet Binding 中将数据源连接到 Knative 目的地

在您选择的编辑器中，创建一个具有以下基本结构的 YAML 文件：

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

为 Kamelet Binding 添加一个名称。在本例中，名称是 coffees-to-knative，因为绑定将 coffee-source Kamelet 连接到一个 Knative 目的地。

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

对于 Kamelet Binding 的源，请指定数据源 Kamelet（例如，coff ee-source Kamelet 会生成事件，其中包含有关 coffee 的数据）并为 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 的 sink，请指定 Knative 频道或代理以及所需参数。

本例将 Knative 频道指定为 sink：

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 代理指定为 sink：

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 命名空间：

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