第 1 章 Kamelets 概述


Kamelets 是高级连接器,可在事件驱动的构架解决方案中用作构建块。它们是您可以在 OpenShift 集群上安装并使用 Camel K 集成的自定义资源。Kamelets 加速您的开发工作。它们简化了您如何连接数据源(发出事件)和数据接收器(消耗事件)。由于您配置 Kamelet 参数而不是编写代码,因此您不需要熟悉 Camel DSL 以使用 Kamelets。

您可以使用 Kamelets 将应用程序和服务直接连接到彼此,或者:

1.1. 关于 Kamelets

Kamelets 是路由组件(封装代码),可在 Camel 集成中作为连接器。您可以将 Kamelets 视为模板,定义要从(源)消耗数据的位置,以及将数据发送到(sink)的位置 - 允许您编译数据管道。Kamelets 也可以过滤、掩码和对数据执行简单的计算逻辑。

Kamelets 有三种不同类型的:

  • Source - 生成数据的路由。您可以使用 source Kamelet 从组件检索数据。
  • sink - 消耗数据的路由。您可以使用 sink Kamelet 将数据发送到组件。
  • action - 对数据执行操作的路由。当从源 Kamelet 传递给 sink Kamelet 时,您可以使用操作 Kamelet 操作数据。

1.1.1. 为什么使用 Kamelets?

微服务和 事件驱动的构架解决方案中,K Kamelets 可以充当发出事件和接收器消耗事件的源的构建块。

Kamelets 提供抽象(隐藏了连接到外部系统的复杂性)和可重复利用(它们是重复使用代码并将其应用到不同的用例的简单方法)。

以下是一些用例示例:

  • 您希望您的应用程序消费来自 Telegram 的事件,您可以使用 Kamelets 将 Telegram 源绑定到事件的频道。之后,您可以将应用程序连接到该频道,以便它响应这些事件。
  • 您希望您的应用程序将 Salesforce 直接连接到 Slack。

Kamelets 允许您和您的集成开发团队更加高效。您可以重复使用 Kamelets,并将它们与可以根据自己的特定需求配置实例的团队成员共享。底层 Camel K 操作器进行硬工作:编译、构建、软件包并部署 Kamelet 定义的集成。

1.1.2. 谁使用 Kamelets?

因为 Kamelets 允许您减少 Camel 集成中所需的编码量,所以非常适合不熟悉 Camel DSL 的开发人员。Kamelets 可以帮助为非活动开发人员平稳完成学习曲线。无需学习其他框架或语言即可让 Camel 运行。

Kamelets 对于希望将复杂的 Camel 集成逻辑封装为可重复使用的 Kamelet 的经验丰富的 Camel 开发人员也很有用,然后与其他用户共享。

1.1.3. 使用 Kamelets 的先决条件是什么?

要使用 Kamelets,您需要以下环境设置:

  • 您可以使用正确的访问级别访问 OpenShift 4.6 (或更新版本)集群、创建项目并安装 Operator,以及在本地系统中安装 OpenShift 和 Camel K CLI 工具的功能。
  • 您在命名空间或集群范围安装了 Camel K operator,如安装 Camel K所述
  • 已安装 OpenShift 命令行(oc)接口工具。
  • 另外,您还可使用 Camel K 插件安装 VS 代码或其他开发工具。基于 Camel 的工具扩展包括基于嵌入式 Kamelet 目录自动完成 Camel URI 的功能。如需更多信息,请参阅 Camel K 入门中的 Camel K 开发工具部分。

    注意: Visual Studio (VS)代码工具扩展仅是社区的。

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 应该做什么。

在运行时,Camel K 操作器使用 Kamelet Binding 生成并运行 Camel K 集成。

注: 虽然 Camel DSL 开发人员可以直接在 Camel K 集成中使用 Kamelets,但实施 Kamelets 的简化方法是通过指定 Kamelet Binding 资源来构建高级别事件流。

Red Hat logoGithubRedditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

通过我们的产品和服务,以及可以信赖的内容,帮助红帽用户创新并实现他们的目标。

让开源更具包容性

红帽致力于替换我们的代码、文档和 Web 属性中存在问题的语言。欲了解更多详情,请参阅红帽博客.

關於紅帽

我们提供强化的解决方案,使企业能够更轻松地跨平台和环境(从核心数据中心到网络边缘)工作。

© 2024 Red Hat, Inc.