第 7 章 订阅

先决条件

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

验证

• 创建订阅后，您可以在 Topology 视图中将频道连接到该服务的行显示为：

  

  View larger image

  

先决条件

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

流程

• 创建 Subscription 对象：

  • 创建 YAML 文件并将以下示例代码复制到其中：

    apiVersion: messaging.knative.dev/v1
    kind: Subscription
    metadata:
      name: my-subscription 

    1

    
      namespace: default
    spec:
      channel: 

    2

    
        apiVersion: messaging.knative.dev/v1
        kind: Channel
        name: example-channel
      delivery: 

    3

    
        deadLetterSink:
          ref:
            apiVersion: serving.knative.dev/v1
            kind: Service
            name: error-handler
      subscriber: 

    4

    
        ref:
          apiVersion: serving.knative.dev/v1
          kind: Service
          name: event-display

    Copy to Clipboard Toggle word wrap

    1

    订阅的名称。

    2

    订阅连接的频道的配置设置。

    3

    事件交付的配置设置。这会告诉订阅无法发送给订阅者的事件。配置后，消耗的事件会发送到 deadLetterSink。事件将被丢弃，不会尝试重新发送该事件，并在系统中记录错误。deadLetterSink 的值需要是一个 Destination。

    4

    订阅用户的配置设置。这是事件从频道发送的事件 sink。

  • 应用 YAML 文件：

    $ oc apply -f <filename>

    Copy to Clipboard Toggle word wrap

先决条件

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

流程

• 创建订阅以将接收器连接到频道：

  $ kn subscription create <subscription_name> \
    --channel <group:version:kind>:<channel_name> \ 

  1

  
    --sink <sink_prefix>:<sink_name> \ 

  2

  
    --sink-dead-letter <sink_prefix>:<sink_name> 

  3

  Copy to Clipboard Toggle word wrap

  1

  --channel 指定应处理的云事件的来源。您必须提供频道名称。如果您没有使用由 Channel 自定义资源支持的默认 InMemoryChannel 频道，您必须为指定频道类型添加 <group:version:kind> 前缀。例如，这是 Apache Kafka 支持的频道的 messaging.knative.dev:v1beta1:KafkaChannel。

  2

  --sink 指定事件要传送到的目标目的地。默认情况下，<sink_name> 解释为此名称的 Knative 服务，与订阅位于同一个命名空间中。您可以使用以下前缀之一指定接收器类型：

  ksvc

  Knative 服务。

  channel

  作为目的地的频道。这里只能引用默认频道类型。

  broker

  Eventing 代理。

  3

  可选： --sink-dead-letter 是一个可选标志，可用于指定在无法发送事件时哪些事件应发送到的接收器。如需更多信息，请参阅 OpenShift Serverless 事件交付文档。

  示例命令

  $ kn subscription create mysubscription --channel mychannel --sink ksvc:event-display

  Copy to Clipboard Toggle word wrap

  输出示例

  Subscription 'mysubscription' created in namespace 'default'.

  Copy to Clipboard Toggle word wrap

验证

• 要确认频道已连接到事件接收器或 subscriber，使用一个订阅列出现有订阅并检查输出：

  $ kn subscription list

  Copy to Clipboard Toggle word wrap

  输出示例

  NAME            CHANNEL             SUBSCRIBER           REPLY   DEAD LETTER SINK   READY   REASON
  mysubscription   Channel:mychannel   ksvc:event-display                              True

  Copy to Clipboard Toggle word wrap

删除订阅

• 删除订阅：

  $ kn subscription delete <subscription_name>

  Copy to Clipboard Toggle word wrap

• 配置事件交付参数，当事件无法发送到事件 sink 时。