5.5. 事件 sink

创建事件源时，您可以指定事件从源发送到的接收器。sink 是一个可寻址或可调用的资源，可以从其他资源接收传入的事件。Knative 服务、频道和代理都是接收器示例。

可寻址的对象接收和确认通过 HTTP 发送的事件到其 status.address.url 字段中定义的地址。作为特殊情况，核心 Kubernetes Service 对象也履行可寻址的接口。

可调用的对象可以接收通过 HTTP 发送的事件并转换事件，并在 HTTP 响应中返回 0 或 1 新事件。这些返回的事件可能会象处理外部事件源中的事件一样进一步处理。

5.5.1. Knative CLI sink 标记

当使用 Knative (kn) CLI 创建事件源时，您可以使用 --sink 标志指定事件从该资源发送到的接收器。sink 可以是任何可寻址或可调用的资源，可以从其他资源接收传入的事件。

以下示例创建使用服务 http://event-display.svc.cluster.local 的接收器绑定作为接收器：

使用 sink 标记的命令示例

$ kn source binding create bind-heartbeat \
  --namespace sinkbinding-example \
  --subject "Job:batch/v1:app=heartbeat-cron" \
  --sink http://event-display.svc.cluster.local \ 1
  --ce-override "sink=bound"

1
http://event-display.svc.cluster.local 中的 svc 确定接收器是一个 Knative 服务。其他默认的接收器前缀包括 channel 和 broker。
提示

您可以通过自定义 kn，配置哪些 CR 可在 Knative (kn) CLI 命令中使用 --sink 标记。

5.5.2. 使用 Developer 视角将事件源连接到接收器（sink）

当使用 OpenShift Container Platform Web 控制台创建事件源时，您可以指定事件从该源发送到的接收器。sink 可以是任何可寻址或可调用的资源，可以从其他资源接收传入的事件。

先决条件

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

流程

  1. 进入 +Add → Event Source 并选择您要创建的事件源类型，创建任何类型的事件源。
  2. 在 Create Event Source 表单视图的 Sink 部分，在 Resource 列表中选择您的接收器。
  3. 点 Create。

验证

您可以通过查看 Topology 页面来验证事件源是否已创建并连接到 sink。

  1. 在 Developer 视角中，导航到 Topology。
  2. 查看事件源并点连接的接收器查看右侧面板中的接收器详情。

5.5.3. 将触发器连接到 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

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