使用 Sequence、Broker 和 Trigger¶

我们将创建以下逻辑配置。我们创建一个 PingSource，将事件输入到 Broker，然后我们创建一个 Filter，将这些事件连接到由 3 个步骤组成的 Sequence。然后我们获取 Sequence 的末尾并将新生成的事件反馈回 Broker，并创建另一个 Trigger，该 Trigger 将显示这些事件。

先决条件¶

Knative Serving
InMemoryChannel

注意

示例使用 default 命名空间。

如果您想使用不同类型的 Channel，您将不得不修改 Sequence.Spec.ChannelTemplate 以创建适当的 Channel 资源。

Logical Configuration

这些示例中使用的函数位于 https://github.com/knative/eventing/blob/main/cmd/appender/main.go。

设置¶

创建 Broker¶

要创建集群默认 Broker 类型，请将以下 YAML 复制到文件中

apiVersion: eventing.knative.dev/v1
kind: Broker
metadata:
 name: default

通过运行命令应用 YAML 文件
```
kubectl apply -f <filename>.yaml
```
其中 <filename> 是您在上一步中创建的文件的名称。

创建 Knative 服务¶

apiVersion: serving.knative.dev/v1
kind: Service
metadata:
  name: first
spec:
  template:
    spec:
      containers:
        - image: gcr.io/knative-releases/knative.dev/eventing/cmd/appender
          env:
            - name: MESSAGE
              value: " - Handled by 0"

---
apiVersion: serving.knative.dev/v1
kind: Service
metadata:
  name: second
spec:
  template:
    spec:
      containers:
        - image: gcr.io/knative-releases/knative.dev/eventing/cmd/appender
          env:
            - name: MESSAGE
              value: " - Handled by 1"
---
apiVersion: serving.knative.dev/v1
kind: Service
metadata:
  name: third
spec:
  template:
    spec:
      containers:
        - image: gcr.io/knative-releases/knative.dev/eventing/cmd/appender
          env:
            - name: MESSAGE
              value: " - Handled by 2"
            - name: TYPE
              value: "samples.http.mod3"
---

更改以下命令中的 default 以在已配置 Broker 的命名空间中创建服务

kubectl -n default create -f ./steps.yaml

创建序列¶

sequence.yaml 文件包含创建序列的规范。如果您使用不同类型的通道，则需要更改 spec.channelTemplate 以指向您想要的通道。

此外，更改 spec.reply.name 以指向您的 Broker

apiVersion: flows.knative.dev/v1
kind: Sequence
metadata:
  name: sequence
spec:
  channelTemplate:
    apiVersion: messaging.knative.dev/v1
    kind: InMemoryChannel
  steps:
    - ref:
        apiVersion: serving.knative.dev/v1
        kind: Service
        name: first
    - ref:
        apiVersion: serving.knative.dev/v1
        kind: Service
        name: second
    - ref:
        apiVersion: serving.knative.dev/v1
        kind: Service
        name: third
  reply:
    ref:
      kind: Broker
      apiVersion: eventing.knative.dev/v1
      name: default

更改以下命令中的 default 以在已配置 Broker 的命名空间中创建 sequence

kubectl -n default create -f ./sequence.yaml

创建目标为 Broker 的 PingSource¶

这将创建一个 PingSource，它将每 2 分钟发送一个 CloudEvent，其数据负载为 {"message": "Hello world!"}。

apiVersion: sources.knative.dev/v1
kind: PingSource
metadata:
  name: ping-source
spec:
  schedule: "*/2 * * * *"
  contentType: "application/json"
  data: '{"message": "Hello world!"}'
  sink:
    ref:
      apiVersion: eventing.knative.dev/v1
      kind: Broker
      name: default

更改以下命令中的 default 以在已配置 broker 和 sequence 的命名空间中创建 PingSource

kubectl -n default create -f ./ping-source.yaml

创建目标为 Sequence 的 Trigger¶

apiVersion: eventing.knative.dev/v1
kind: Trigger
metadata:
  name: sequence-trigger
spec:
  broker: default
  filter:
    attributes:
      type: dev.knative.sources.ping
  subscriber:
    ref:
      apiVersion: flows.knative.dev/v1
      kind: Sequence
      name: sequence

更改以下命令中的 default 以在已配置 broker 和 sequence 的命名空间中创建 trigger

kubectl -n default create -f ./trigger.yaml

创建 Service 和 Trigger 以显示 Sequence 生成的事件¶

apiVersion: serving.knative.dev/v1
kind: Service
metadata:
  name: sequence-display
spec:
  template:
    spec:
      containers:
        - image: gcr.io/knative-releases/knative.dev/eventing/cmd/event_display
---
apiVersion: eventing.knative.dev/v1
kind: Trigger
metadata:
  name: display-trigger
spec:
  broker: default
  filter:
    attributes:
      type: samples.http.mod3
  subscriber:
    ref:
      apiVersion: serving.knative.dev/v1
      kind: Service
      name: sequence-display
---

更改以下命令中的 default 以在已配置 broker 的命名空间中创建 service 和 trigger

kubectl -n default create -f ./display-trigger.yaml

检查结果¶

您现在可以通过检查 sequence-display pod 的日志来查看最终输出。

kubectl -n default get pods

查看 sequence-display pod 的日志

kubectl -n default logs -l serving.knative.dev/service=sequence-display -c user-container --tail=-1
☁️  cloudevents.Event
Validation: valid
Context Attributes,
  specversion: 1.0
  type: samples.http.mod3
  source: /apis/v1/namespaces/default/pingsources/ping-source
  id: 159bba01-054a-4ae7-b7be-d4e7c5f773d2
  time: 2020-03-03T14:56:00.000652027Z
  datacontenttype: application/json
Extensions,
  knativearrivaltime: 2020-03-03T14:56:00.018390608Z
  knativehistory: default-kne-trigger-kn-channel.default.svc.cluster.local; sequence-kn-sequence-0-kn-channel.default.svc.cluster.local; sequence-kn-sequence-1-kn-channel.default.svc.cluster.local; sequence-kn-sequence-2-kn-channel.default.svc.cluster.local; default-kne-trigger-kn-channel.default.svc.cluster.local
  traceparent: 00-e893412106ff417a90a5695e53ffd9cc-5829ae45a14ed462-00
Data,
  {
    "id": 0,
    "message": "Hello world! - Handled by 0 - Handled by 1 - Handled by 2"
  }

您可以看到初始 PingSource 消息 {"Hello World!"} 已被 Sequence 中的每个步骤追加。