第 1 章 Kamelets 概述
Kamelets 是高级连接器,可以在事件驱动的构架解决方案中充当构建块。它们是您可以在 OpenShift 集群上安装的自定义资源,并在 Camel K 集成中使用。Kamelets 可以加速您的开发工作。它们简化了如何连接数据源(释放事件)和数据 sink(消耗事件)。由于配置 Kamelet 参数而不是编写代码,因此无需熟悉 Camel DSL 来使用 Kamelets。
您可以使用 Kamelets 相互直接连接应用程序和服务,或:
- Kafka 主题,如 连接到带有 Kamelets 的 Kafka 所述。
- Knative 目的地(channels 或 brokers),如使用 Kamelets 连接到 Knative 所述。
- 具体 Camel URI,如 连接到显式 Camel URI 所述。
1.1. 关于 Kamelets
Kamelets 是路由组件(已封装代码),在 Camel 集成中作为连接器工作。您可以将 Kamelets 视为模板,用于定义从(源)来消耗数据的位置,以及将数据发送到(sink)- 允许您编译数据管道。Kamelets 也可以过滤、掩码并对数据执行简单的计算逻辑。
Kamelets 有三种不同类型的:
- Source - 生成数据的路由。您可以使用一个源 Kamelet 从组件中检索数据。
- sink - 使用数据的路由。您可以使用 sink Kamelet 将数据发送到组件。
- 操作 - 对数据执行操作的路由。您可以使用一个操作 Kamelet 在从源 Kamelet 传递给一个 sink Kamelet 时操作数据。
1.1.1. 为什么使用 Kamelets?
在 微服务和 事件驱动的构架解决方案中,K Kamelets 可以充当发出事件和接收器(sink)的源的构建块。
Kamelets 提供抽象(它们隐藏连接到外部系统的复杂性)和可重复利用代码并将其应用到不同的用例的简单方法。
以下是一些用例:
- 您希望应用程序消耗来自 Telegram 的事件,您可以使用 Kamelets 将 Telegram 源绑定到事件的频道。之后,您可以将应用程序连接到该频道,以便它对这些事件做出反应。
- 您希望应用程序直接连接到 Slack。
Kamelets 允许您和您的集成开发团队提升效率。您可以重复使用 Kamelets,并与可为其具体需求配置实例的团队成员共享它们。底层 Camel K Operator 执行硬工作:它编译、构建、打包并部署 Kamelet 定义的集成。
1.1.2. 谁使用 Kamelets?
由于 Kamelets 能让您减少 Camel 集成中所需的编码数量,所以它们非常适合不熟悉 Camel DSL 的开发人员。Kamelets 可以帮助实现非Camel 开发者的学习曲线。您无需学习其他框架或语言才能运行 Camel。
Kamelets 对希望将复杂 Camel 集成逻辑封装成可重复使用的 Kamelet 的经验丰富的 Camel 开发人员也很有用,然后与其他用户共享。
1.1.3. 使用 Kamelets 的先决条件是什么?
要使用 Kamelets,您需要以下环境设置:
- 您可以使用正确的访问级别访问 OpenShift 4.6(或更新版本)集群、创建项目和安装 Operator 的功能,并可在本地系统上安装 OpenShift 和 Camel K CLI 工具。
- 您需要在命名空间或集群范围安装 Camel K 操作器,如 安装 Camel K所述
-
已安装 OpenShift 命令行(
oc
)接口工具。 另外,您可以使用 Camel K 插件安装 VS 代码或其他开发工具。基于 Camel 的工具扩展包括基于嵌入式 Kamelet Catalog 自动完成 Camel URI 的功能。如需更多信息,请参阅 Camel K 入门 中的 Camel K 开发工具 部分。
注意: Visual Studio(VS)Code 工具扩展仅限于社区。
1.1.4. 如何使用 Kamelets?
使用 Kamelet 通常涉及两个组件:K Kamelet 本身(它定义了一个可重复使用的路由片断)和一个 Kamelet Binding,供您引用并绑定到一个或多个 Kamelets。Kamelet Binding 是一个 OpenShift 资源(KameletBinding
)。
在 Kamelet Binding 资源中,您可以:
- 将接收器或源 Kamelet 连接到事件频道: Kafka 主题或 Knative 目标(channel 或 broker)。
- 将 sink Kamelet 直接连接到 Camel 统一资源标识符(URI)。您还可以将源 Kamelet 连接到 Camel URI,虽然连接 URI 和 sink Kamelet 是最常见的用例。
- 将 sink 和一个源 Kamelet 直接相互连接,而无需将事件频道用作中间层。
- 在同一个 Kamelet Binding 中多次引用相同的 Kamelet。
- 添加 action Kamelets,以在从源 Kamelet 传递到 sink Kamelet 时操作数据。
- 定义错误处理策略,以指定在发送或接收事件数据时应执行 Camel K 做什么。
在运行时,Camel K 操作器使用 Kamelet Binding 生成并运行 Camel K 集成。
注: 虽然 Camel DSL 开发人员可以在 Camel K 集成中直接使用 Kamelets,但实施 Kamelet 的更简单方法是指定 Kamelet 资源来构建高级别的事件流。