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