3.4. 运行 Camel K 集成
您可以使用 kamel run 命令从命令行运行 OpenShift 集群的云中 Camel K 集成。
先决条件
- 设置您的 Camel K 开发环境。
- 您必须已经使用 Java 或 YAML DSL 编写 Camel 集成。
流程
使用
oc客户端工具登录到 OpenShift 集群，例如：$ oc login --token=my-token --server=https://my-cluster.example.com:6443
确保 Camel K Operator 正在运行，例如：
$ oc get pod NAME READY STATUS RESTARTS AGE camel-k-operator-86b8d94b4-pk7d6 1/1 Running 0 6m28s
输入
kamel run命令，以在 OpenShift 的云中运行您的集成。例如：Java 示例
$ kamel run HelloCamelK.java integration "hello-camel-k" created
YAML 示例
$ kamel run hello.camelk.yaml integration "hello" created
输入
kamel get命令检查集成的状态：$ kamel get NAME PHASE KIT hello Building Kit myproject/kit-bq666mjej725sk8sn12g
当集成第一次运行时，Camel K 会为容器镜像构建集成工具包，它会下载所有所需的 Camel 模块并将其添加到镜像 classpath 中。
再次输入
kamel get来验证集成是否正在运行：$ kamel get NAME PHASE KIT hello Running myproject/kit-bq666mjej725sk8sn12g
输入
kamel log命令将日志输出到stdout：$ kamel log hello [1] 2021-08-11 17:58:40,573 INFO [org.apa.cam.k.Runtime] (main) Apache Camel K Runtime 1.7.1.fuse-800025-redhat-00001 [1] 2021-08-11 17:58:40,653 INFO [org.apa.cam.qua.cor.CamelBootstrapRecorder] (main) bootstrap runtime: org.apache.camel.quarkus.main.CamelMainRuntime [1] 2021-08-11 17:58:40,844 INFO [org.apa.cam.k.lis.SourcesConfigurer] (main) Loading routes from: SourceDefinition{name='camel-k-embedded-flow', language='yaml', location='file:/etc/camel/sources/camel-k-embedded-flow.yaml', } [1] 2021-08-11 17:58:41,216 INFO [org.apa.cam.imp.eng.AbstractCamelContext] (main) Routes startup summary (total:1 started:1) [1] 2021-08-11 17:58:41,217 INFO [org.apa.cam.imp.eng.AbstractCamelContext] (main) Started route1 (timer://yaml) [1] 2021-08-11 17:58:41,217 INFO [org.apa.cam.imp.eng.AbstractCamelContext] (main) Apache Camel 3.10.0.fuse-800010-redhat-00001 (camel-1) started in 136ms (build:0ms init:100ms start:36ms) [1] 2021-08-11 17:58:41,268 INFO [io.quarkus] (main) camel-k-integration 1.6.6 on JVM (powered by Quarkus 1.11.7.Final-redhat-00009) started in 2.064s. [1] 2021-08-11 17:58:41,269 INFO [io.quarkus] (main) Profile prod activated. [1] 2021-08-11 17:58:41,269 INFO [io.quarkus] (main) Installed features: [camel-bean, camel-core, camel-k-core, camel-k-runtime, camel-log, camel-support-common, camel-timer, camel-yaml-dsl, cdi] [1] 2021-08-11 17:58:42,423 INFO [info] (Camel (camel-1) thread #0 - timer://yaml) Exchange[ExchangePattern: InOnly, BodyType: String, Body: Hello Camel K from yaml] ...-
按
Ctrl-C终止终端中的日志记录。
其他资源
-
有关
kamel run命令的更多详细信息，请输入kamel run --help - 有关更快地部署时间，请参阅在 开发模式下运行 Camel K 集成
- 有关运行集成的开发工具的详情，请参阅 VS Code Tooling for Apache Camel K by Red Hat
- 另请参阅 管理 Camel K 集成
在不使用 CLI 的情况下运行集成
您可以在没有 CLI (Command Line Interface)的情况下运行 集成自定义资源，并使用配置创建一个集成自定义资源 来运行应用程序。
例如，执行以下示例路由。
kamel run Sample.java -o yaml
它返回预期的 Integration 自定义资源。
apiVersion: camel.apache.org/v1
kind: Integration
metadata:
creationTimestamp: null
name: my-integration
namespace: default
spec:
sources:
- content: "
import org.apache.camel.builder.RouteBuilder;
public class Sample extends RouteBuilder {
@Override
public void configure()
throws Exception {
from(\"timer:tick\")
.log(\"Hello Integration!\");
}
}"
name: Sample.java
status: {}
将此自定义资源保存到 yaml 文件 my-integration.yaml 中。现在，使用 oc 命令行、UI 或 API 来调用 OpenShift 集群，运行包含 Integration 自定义资源的集成。在以下示例中，从命令行使用 oc CLI。
oc apply -f my-integration.yaml ... integration.camel.apache.org/my-integration created
Operator 运行集成。
- Kubernetes 支持 CustomResourceDefinitions 的 Structural Schema。
- 有关 Camel K traits 的详情，请参阅 Camel K trait 配置参考。
自定义资源的 schema 更改
强大的 Trait API 会对以下 CustomResourceDefinitions 实施更改： 集成、集成工具包'和"集成平台"。
spec.traits.<trait-id>.configuration 下的特征属性现在直接在 spec.traits.<trait-id> 下定义。
traits:
container:
configuration:
enabled: true
name: my-integration↓↓↓
traits:
container:
enabled: true
name: my-integration
这种实现中有可能向后兼容。为实现向后兼容，请为每个特征类型提供带有 RawMessage 类型的 Configuration 字段，以便从现有集成和资源从新的 Camel K 版本读取。
当读取旧的集成和资源时，每个特征（若有）中的旧配置将迁移到新的 Trait API 字段。如果在新的 API 字段中预定义了值，它们会在旧的 API 字段前面。
type Trait struct {
// Can be used to enable or disable a trait. All traits share this common property.
Enabled *bool `property:"enabled" json:"enabled,omitempty"`
// Legacy trait configuration parameters.
// Deprecated: for backward compatibility.
Configuration *Configuration `json:"configuration,omitempty"`
}
// Deprecated: for backward compatibility.
type Configuration struct {
RawMessage `json:",inline"`
}