Red Hat Summit 红帽全球峰会支持控制台（Console）开发人员开始试用联系人

5.5. 触发器

5.5.1. 触发器概述
复制链接

代理可与触发器结合使用，用于将事件源发送到事件 sink。事件从事件源发送到代理，作为 HTTP POST 请求。事件进入代理后，可使用触发器根据 CloudEvent 属性 进行过滤，并作为 HTTP POST 请求发送到事件 sink。

代理事件交付概述
View larger image
代理事件交付概述

如果使用 Kafka 代理，您可以将事件的交付顺序从触发器配置为事件 sink。请参阅为触发器配置事件交付顺序。

5.5.1.1. 为触发器配置事件交付顺序
复制链接

如果使用 Kafka 代理，您可以将事件的交付顺序从触发器配置为事件 sink。

先决条件

  • OpenShift Serverless Operator、Knative Eventing 和 Knative Kafka 安装在 OpenShift Container Platform 集群中。
  • Kafka 代理被启用在集群中使用，您也创建了一个 Kafka 代理。
  • 您已创建了一个项目，或者具有适当的角色和权限访问项目，以便在 OpenShift Container Platform 中创建应用程序和其他工作负载。
  • 已安装 OpenShift (oc) CLI。

流程

  1. 创建或修改 Trigger 对象并设置 kafka.eventing.knative.dev/delivery.order 注解： 

    apiVersion: eventing.knative.dev/v1
kind: Trigger
metadata:
  name: <trigger_name>
  annotations:
     kafka.eventing.knative.dev/delivery.order: ordered
...
    Copy to Clipboard Toggle word wrap

    支持的消费者交付保证有：

    unordered
    未排序的消费者是一种非阻塞消费者，它能以未排序的方式提供消息，同时保持正确的偏移管理。
    排序的

    一个订购的消费者是一个按分区阻止消费者，在提供分区的下一个消息前等待来自 CloudEvent 订阅者成功响应。

    默认排序保证是 unordered。

  2. 应用 Trigger 对象： 

    $ oc apply -f <filename>
    Copy to Clipboard Toggle word wrap

5.5.1.2. 后续步骤
复制链接

5.5.2. 创建触发器
复制链接

代理可与触发器结合使用，用于将事件源发送到事件 sink。事件从事件源发送到代理，作为 HTTP POST 请求。事件进入代理后，可使用触发器根据 CloudEvent 属性 进行过滤，并作为 HTTP POST 请求发送到事件 sink。

代理事件交付概述
View larger image
代理事件交付概述

5.5.2.1. 使用 Administrator 视角创建触发器
复制链接

使用 OpenShift Container Platform Web 控制台提供了一个简化且直观的用户界面来创建触发器。在集群中安装 Knative Eventing 并创建了代理后，您可以使用 web 控制台创建触发器。

先决条件

  • OpenShift Serverless Operator 和 Knative Eventing 已安装在 OpenShift Container Platform 集群中。
  • 您已登录到 Web 控制台，且处于 Administrator 视角。
  • 具有集群管理员 OpenShift Container Platform 的权限。
  • 您已创建了 Knative 代理。
  • 您已创建了 Knative 服务以用作订阅者。

流程

  1. 在 OpenShift Container Platform Web 控制台的 Administrator 视角中，导航到 Serverless Eventing。
  2. 在 Broker 选项卡中，为您要在其中添加触发器的代理选择 Options 菜单 kebab 。
  3. 点列表中的 Add Trigger。
  4. 在 Add Trigger 对话框中，为触发器选择 Subscriber。订阅者是可以从代理接收事件的 Knative 服务。
  5. 点击 Add。

5.5.2.2. 使用 Developer 视角创建触发器
复制链接

使用 OpenShift Container Platform Web 控制台提供了一个简化且直观的用户界面来创建触发器。在集群中安装 Knative Eventing 并创建了代理后，您可以使用 web 控制台创建触发器。

先决条件

  • OpenShift Serverless Operator、Knative Serving 和 Knative Eventing 已在 OpenShift Container Platform 集群中安装。
  • 已登陆到 web 控制台。
  • 您已创建了一个项目，或者具有适当的角色和权限访问项目，以便在 OpenShift Container Platform 中创建应用程序和其他工作负载。
  • 您已创建了代理和 Knative 服务或其他事件 sink 以连接触发器。

流程

  1. 在 Developer 视角中，进入 Topology 页。
  2. 将鼠标悬停在您要创建触发器的代理上，并拖动箭头。此时会显示 Add Trigger 选项。
  3. 点 Add Trigger。
  4. 在 Subscriber 列表中选择您的接收器。
  5. 点 Add。

验证

  • 创建订阅后，您可以在 Topology 页面中查看它，其中它是一个将代理连接到事件 sink 的行。

删除触发器

  1. 在 Developer 视角中，进入 Topology 页。
  2. 点您要删除的触发器。
  3. 在 Actions 上下文菜单中，选择 Delete Trigger。

5.5.2.3. 使用 Knative CLI 创建触发器
复制链接

您可以使用 kn trigger create 命令创建触发器。

先决条件

  • OpenShift Serverless Operator 和 Knative Eventing 已安装在 OpenShift Container Platform 集群中。
  • 已安装 Knative (kn) CLI。
  • 您已创建了一个项目，或者具有适当的角色和权限访问项目，以便在 OpenShift Container Platform 中创建应用程序和其他工作负载。

流程

  • 创建触发器： 

    $ kn trigger create <trigger_name> --broker <broker_name> --filter <key=value> --sink <sink_name>
    Copy to Clipboard Toggle word wrap

    或者，您可以创建触发器并使用代理注入同时创建 default 代理： 

    $ kn trigger create <trigger_name> --inject-broker --filter <key=value> --sink <sink_name>
    Copy to Clipboard Toggle word wrap

    默认情况下，触发器会将发送到代理的所有事件转发到订阅到该代理的 sink。通过对触发器使用 --filter 属性，您可以从代理过滤事件，这样订阅者才会根据您定义的标准接收一小部分事件。

5.5.3. 从命令行列出触发器
复制链接

使用 Knative (kn) CLI 列出触发器提供精简、直观的用户界面。

5.5.3.1. 使用 Knative CLI 列出触发器
复制链接

您可以使用 kn trigger list 命令列出集群中的现有触发器。

先决条件

  • OpenShift Serverless Operator 和 Knative Eventing 已安装在 OpenShift Container Platform 集群中。
  • 已安装 Knative (kn) CLI。

流程

  1. 显示可用触发器列表： 

    $ kn trigger list
    Copy to Clipboard Toggle word wrap

    输出示例

    NAME    BROKER    SINK           AGE   CONDITIONS   READY   REASON
email   default   ksvc:edisplay   4s    5 OK / 5     True
ping    default   ksvc:edisplay   32s   5 OK / 5     True
    Copy to Clipboard Toggle word wrap

  2. 可选：以 JSON 格式输出触发器列表： 

    $ kn trigger list -o json
    Copy to Clipboard Toggle word wrap

5.5.4. 描述从命令行中的触发器
复制链接

使用 Knative (kn) CLI 描述触发器，提供了一个简化且直观的用户界面。

5.5.4.1. 使用 Knative CLI 描述触发器
复制链接

您可以通过 kn trigger describe 命令使用 Knative CLI 输出集群中现有触发器的信息。

先决条件

  • OpenShift Serverless Operator 和 Knative Eventing 已安装在 OpenShift Container Platform 集群中。
  • 已安装 Knative (kn) CLI。
  • 您已创建了触发器。

流程

  • 输入命令： 

    $ kn trigger describe <trigger_name>
    Copy to Clipboard Toggle word wrap

    输出示例

    Name:         ping
Namespace:    default
Labels:       eventing.knative.dev/broker=default
Annotations:  eventing.knative.dev/creator=kube:admin, eventing.knative.dev/lastModifier=kube:admin
Age:          2m
Broker:       default
Filter:
  type:       dev.knative.event

Sink:
  Name:       edisplay
  Namespace:  default
  Resource:   Service (serving.knative.dev/v1)

Conditions:
  OK TYPE                  AGE REASON
  ++ Ready                  2m
  ++ BrokerReady            2m
  ++ DependencyReady        2m
  ++ Subscribed             2m
  ++ SubscriberResolved     2m
    Copy to Clipboard Toggle word wrap

5.5.5. 将触发器连接到 sink
复制链接

您可以将触发器连接到 sink，以便在将代理的事件发送到 sink 前过滤代理的事件。在 Trigger 对象的资源规格中，连接到触发器的 sink 会配置为 订阅者。

连接到 Kafka sink 的 Trigger 对象示例

apiVersion: eventing.knative.dev/v1
kind: Trigger
metadata:
  name: <trigger_name>
1 

spec:
...
  subscriber:
    ref:
      apiVersion: eventing.knative.dev/v1alpha1
      kind: KafkaSink
      name: <kafka_sink_name>
2
Copy to Clipboard Toggle word wrap

1
连接到 sink 的触发器的名称。
2
KafkaSink 对象的名称。

5.5.6. 从命令行过滤触发器
复制链接

使用 Knative (kn) CLI 使用 kn CLI 通过触发器过滤事件，可提供精简且直观的用户界面。您可以使用 kn trigger create 命令和适当的标记来通过使用触发器过滤事件。

5.5.6.1. 使用 Knative CLI 使用触发器过滤事件
复制链接

在以下触发器示例中，只有带有属性 type: dev.knative.samples.helloworld 的事件才会发送到事件 sink: 

$ kn trigger create <trigger_name> --broker <broker_name> --filter type=dev.knative.samples.helloworld --sink ksvc:<service_name>
Copy to Clipboard Toggle word wrap

您还可以使用多个属性过滤事件。以下示例演示了如何使用类型、源和扩展属性过滤事件： 

$ kn trigger create <trigger_name> --broker <broker_name> --sink ksvc:<service_name> \
--filter type=dev.knative.samples.helloworld \
--filter source=dev.knative.samples/helloworldsource \
--filter myextension=my-extension-value
Copy to Clipboard Toggle word wrap

5.5.7. 从命令行更新触发器
复制链接

使用 Knative (kn) CLI 更新触发器提供精简、直观的用户界面。

5.5.7.1. 使用 Knative CLI 更新触发器
复制链接

您可以使用带有特定标志的 kn trigger update 命令来更新触发器的属性。

先决条件

  • OpenShift Serverless Operator 和 Knative Eventing 已安装在 OpenShift Container Platform 集群中。
  • 已安装 Knative (kn) CLI。
  • 您已创建了一个项目，或者具有适当的角色和权限访问项目，以便在 OpenShift Container Platform 中创建应用程序和其他工作负载。

流程

  • 更新触发器： 

    $ kn trigger update <trigger_name> --filter <key=value> --sink <sink_name> [flags]
    Copy to Clipboard Toggle word wrap

    • 您可以更新触发器来过滤与传入事件匹配的事件属性。例如，使用 type 属性： 

      $ kn trigger update <trigger_name> --filter type=knative.dev.event
      Copy to Clipboard Toggle word wrap

    • 您可以从触发器中删除过滤器属性。例如，您可以使用键 type 来删除过滤器属性： 

      $ kn trigger update <trigger_name> --filter type-
      Copy to Clipboard Toggle word wrap

    • 您可以使用 --sink 参数来更改触发器的事件 sink: 

      $ kn trigger update <trigger_name> --sink ksvc:my-event-sink
      Copy to Clipboard Toggle word wrap

5.5.8. 从命令行删除触发器
复制链接

使用 Knative (kn) CLI 删除触发器提供精简而直观的用户界面。

5.5.8.1. 使用 Knative CLI 删除触发器
复制链接

您可以使用 kn trigger delete 命令删除触发器。

先决条件

  • OpenShift Serverless Operator 和 Knative Eventing 已安装在 OpenShift Container Platform 集群中。
  • 已安装 Knative (kn) CLI。
  • 您已创建了一个项目，或者具有适当的角色和权限访问项目，以便在 OpenShift Container Platform 中创建应用程序和其他工作负载。

流程

  • 删除触发器： 

    $ kn trigger delete <trigger_name>
    Copy to Clipboard Toggle word wrap

验证

  1. 列出现有触发器： 

    $ kn trigger list
    Copy to Clipboard Toggle word wrap

  2. 验证触发器不再存在：

    输出示例

    No triggers found.
    Copy to Clipboard Toggle word wrap

返回顶部
Red Hat logoGithubredditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

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

让开源更具包容性

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

關於紅帽

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

Theme

© 2025 Red Hat