41.3. 使用方法

本节论述了如何使用 json-deserialize-action。

41.3.1. Knative Action

您可以使用 json-deserialize-action Kamelet 作为 Knative 绑定中的中间步骤。

json-deserialize-action-binding.yaml

Copy to Clipboard Toggle word wrap

apiVersion: camel.apache.org/v1alpha1
kind: KameletBinding
metadata:
  name: json-deserialize-action-binding
spec:
  source:
    ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: timer-source
    properties:
      message: "Hello"
  steps:
  - ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: json-deserialize-action
  sink:
    ref:
      kind: Channel
      apiVersion: messaging.knative.dev/v1
      name: mychannel

apiVersion: camel.apache.org/v1alpha1
kind: KameletBinding
metadata:
  name: json-deserialize-action-binding
spec:
  source:
    ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: timer-source
    properties:
      message: "Hello"
  steps:
  - ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: json-deserialize-action
  sink:
    ref:
      kind: Channel
      apiVersion: messaging.knative.dev/v1
      name: mychannel

41.3.1.1. 前提条件

确保您已将 "红帽集成 - Camel K" 安装到您连接的 OpenShift 集群中。

41.3.1.2. 使用集群 CLI 的步骤

将 json-deserialize-action-binding.yaml 文件保存到本地驱动器中，然后根据需要编辑您的配置。

使用以下命令运行操作：

Copy to Clipboard Toggle word wrap

oc apply -f json-deserialize-action-binding.yaml

oc apply -f json-deserialize-action-binding.yaml

41.3.1.3. 使用 Kamel CLI 的步骤

使用以下命令配置和运行操作：

Copy to Clipboard Toggle word wrap

kamel bind timer-source?message=Hello --step json-deserialize-action channel:mychannel

kamel bind timer-source?message=Hello --step json-deserialize-action channel:mychannel

此命令在集群的当前命名空间中创建 KameletBinding。

41.3.2. Kafka Action

您可以使用 json-deserialize-action Kamelet 作为 Kafka 绑定中的中间步骤。

json-deserialize-action-binding.yaml

Copy to Clipboard Toggle word wrap

apiVersion: camel.apache.org/v1alpha1
kind: KameletBinding
metadata:
  name: json-deserialize-action-binding
spec:
  source:
    ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: timer-source
    properties:
      message: "Hello"
  steps:
  - ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: json-deserialize-action
  sink:
    ref:
      kind: KafkaTopic
      apiVersion: kafka.strimzi.io/v1beta1
      name: my-topic

apiVersion: camel.apache.org/v1alpha1
kind: KameletBinding
metadata:
  name: json-deserialize-action-binding
spec:
  source:
    ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: timer-source
    properties:
      message: "Hello"
  steps:
  - ref:
      kind: Kamelet
      apiVersion: camel.apache.org/v1alpha1
      name: json-deserialize-action
  sink:
    ref:
      kind: KafkaTopic
      apiVersion: kafka.strimzi.io/v1beta1
      name: my-topic

41.3.2.1. 先决条件

确保您已在 OpenShift 集群中安装了 AMQ Streams Operator，并在当前命名空间中创建一个名为 my-topic 的主题。另外，请确保已将 "红帽集成 - Camel K" 安装到您连接的 OpenShift 集群中。

41.3.2.2. 使用集群 CLI 的步骤

将 json-deserialize-action-binding.yaml 文件保存到本地驱动器中，然后根据需要编辑您的配置。

使用以下命令运行操作：

Copy to Clipboard Toggle word wrap

oc apply -f json-deserialize-action-binding.yaml

oc apply -f json-deserialize-action-binding.yaml

41.3.2.3. 使用 Kamel CLI 的步骤

使用以下命令配置和运行操作：

Copy to Clipboard Toggle word wrap

kamel bind timer-source?message=Hello --step json-deserialize-action kafka.strimzi.io/v1beta1:KafkaTopic:my-topic

kamel bind timer-source?message=Hello --step json-deserialize-action kafka.strimzi.io/v1beta1:KafkaTopic:my-topic

此命令在集群的当前命名空间中创建 KameletBinding。

返回顶部

41.3. 使用方法

41.3.1. Knative Action

41.3.1.1. 前提条件

41.3.1.2. 使用集群 CLI 的步骤

41.3.1.3. 使用 Kamel CLI 的步骤

41.3.2. Kafka Action

41.3.2.1. 先决条件

41.3.2.2. 使用集群 CLI 的步骤

41.3.2.3. 使用 Kamel CLI 的步骤

学习

尝试、购买和销售

社区

关于红帽文档

让开源更具包容性

關於紅帽

Theme

Red Hat legal and privacy links

Red Hat legal and privacy links