1.2.3. 在 Kamelet Binding 中连接源和接收器组件
在 Kamelet Binding 中,您连接源和接收器组件。
此流程中的示例使用以下 Kamelets,如图 1.2 所示:
-
Source Kamelet 示例 名为
coffee-source
。此简单的 Kamelet 从网站目录中随机检索有关 coffee 类型的数据。它有一个参数(句点
-整数值
),它决定了检索 coffee 数据的频率(以秒为单位)。不需要该参数,因为有默认值(1000 秒)。 -
sink Kamelet 示例名为
log-sink
。它检索数据并将其输出到日志文件中。log-sink
Kamelet 在 Kamelet Catalog 中提供。
图 1.2:K Kamelet Binding 示例
先决条件
- 您已经知道如何创建和编辑 Camel K 集成。
- Red Hat Integration - Camel K operator 安装在 OpenShift 命名空间或集群上,并且已下载了 Red Hat Integration Camel K CLI 工具,如 安装 Camel K 所述。
- 您知道哪个 Kame 可让您添加到 Camel K 集成和所需的实例参数中。
Kamelets 包括在 Kamelet Catalog 中。
在本例中,
log-sink
Kamelet 在 Kamelet Catalog 中提供。如果要使用本例中的源 Kamelet,请将coffee -source 代码
复制到名为coffee-source.kamelet.yaml
的本地文件中,然后运行以下命令将其添加到 Kamelet Catalog:oc apply -f coffee-source.kamelet.yaml
流程
- 登录到您的 OpenShift 集群。
打开安装 Camel K operator 的工作项目。如果您在 cluster-mode 中安装 Camel K operator,则可用于集群中的任何项目。
例如,要打开名为
my-camel-k-project
的现有项目:oc project my-camel-k-project
使用以下选项之一创建新的 Kamelet Binding:
-
使用
kamel bind
命令创建并运行 Kamelet Binding(此选项对于为命令行定义来说,简单 Kamelet Bindings 很有用) 创建一个 YAML 文件来定义 Kamelet Binding,然后使用
oc apply
命令运行它(当 Kamelet Binding 配置更为复杂时,此选项很有用)。使用 kamel bind 命令创建一个新的 Kamelet Binding
使用以下
kamel 绑定
语法指定 source 和 sink 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
在您选择的编辑器中,创建一个带有以下结构的 YAML 文件:
apiVersion: camel.apache.org/v1alpha1 kind: KameletBinding metadata: name: spec: source: sink:
为 Kamelet Binding 添加一个名称。
在本例中,名称是
coffee-to-log
,因为绑定将coffee-source
Kamelet 连接到log-sink
Kamelet。apiVersion: camel.apache.org/v1alpha1 kind: KameletBinding metadata: name: coffee-to-log spec: source: sink:
指定源 Kamelet(例如,coff
ee-source
)并为 Kamelet 配置任何参数。注: 在本例中,参数在 Kamelet Binding 的 YAML 文件中定义。另外,您可以在属性文件、ConfigMap 或 Secret 中配置 Kamelet 的参数,如 配置 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:
指定 sink 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
-
保存 YAML 文件(例如,coff
ee-to-log.yaml
)。 将
KameletBinding
作为 OpenShift 命名空间的资源添加:oc apply -f <kamelet-binding>.yaml
例如:
oc apply -f coffee-to-log.yaml
Camel K operator 使用
KameletBinding
资源生成并运行 Camel K 集成。
-
使用
查看 Kamelet Binding 的状态:
oc get kameletbindings
-
查看对应集成的状态:
oc get integrations
查看输出:
要从命令行查看日志,请打开终端窗口并输入以下命令:
kamel 日志 <integration-name>
例如,如果集成名称为
coffee-to-log
,则使用以下命令:kamel 日志 coffee-to-log
从 OpenShift Web 控制台查看日志:
- 选择 Workloads > Pods。
单击 Camel K 集成 Pod 的名称,然后单击 Logs。
您应该看到类似以下示例的 coffee 事件列表:
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"}
要停止集成,删除 Kamelet Binding:
oc delete kameletbindings/<kameletbinding-name>
例如:
oc delete kameletbindings/coffee-to-log
后续步骤
(可选):
- 添加 action Kamelets 作为中介步骤,如 将操作添加到 Kamelet Binding 所述。
- 在 Kamelet Binding 中添加错误处理,如 Adding a error handler policy to a Kamelet Binding 所述。