2.6. 自定义事件源

流程

1. 要检查接收器绑定是否已正确设置，请创建一个 Knative 事件显示服务或事件接收器，在日志中转储传入的信息。

   1. 创建服务 YAML 文件：

      服务 YAML 文件示例

      apiVersion: serving.knative.dev/v1
      kind: Service
      metadata:
        name: event-display
      spec:
        template:
          spec:
            containers:
              - image: quay.io/openshift-knative/showcase

   2. 创建服务：

      $ oc apply -f <filename>

2. 创建将事件定向到该服务的接收器绑定实例。

   1. 创建接收器绑定 YAML 文件：

      服务 YAML 文件示例

      apiVersion: sources.knative.dev/v1alpha1
      kind: SinkBinding
      metadata:
        name: bind-heartbeat
      spec:
        subject:
          apiVersion: batch/v1
          kind: Job 1
          selector:
            matchLabels:
              app: heartbeat-cron
      
        sink:
          ref:
            apiVersion: serving.knative.dev/v1
            kind: Service
            name: event-display

      1

      在本例中，任何具有标签 app: heartbeat-cron 的作业都将被绑定到事件 sink。

   2. 创建接收器绑定：

      $ oc apply -f <filename>

3. 创建 CronJob 对象。

   1. 创建 cron 任务 YAML 文件：

      Cron Job YAML 文件示例

      apiVersion: batch/v1
      kind: CronJob
      metadata:
        name: heartbeat-cron
      spec:
        # Run every minute
        schedule: "* * * * *"
        jobTemplate:
          metadata:
            labels:
              app: heartbeat-cron
              bindings.knative.dev/include: "true"
          spec:
            template:
              spec:
                restartPolicy: Never
                containers:
                  - name: single-heartbeat
                    image: quay.io/openshift-knative/heartbeats:latest
                    args:
                      - --period=1
                    env:
                      - name: ONE_SHOT
                        value: "true"
                      - name: POD_NAME
                        valueFrom:
                          fieldRef:
                            fieldPath: metadata.name
                      - name: POD_NAMESPACE
                        valueFrom:
                          fieldRef:
                            fieldPath: metadata.namespace

      重要

      要使用接收器绑定，您必须手动在 Knative 资源中添加 bindings.knative.dev/include=true 标签。

      例如，要将此标签添加到 CronJob 资源，请将以下行添加到 Job 资源 YAML 定义中：

        jobTemplate:
          metadata:
            labels:
              app: heartbeat-cron
              bindings.knative.dev/include: "true"

   2. 创建 cron job：

      $ oc apply -f <filename>

4. 输入以下命令并检查输出，检查是否正确映射了控制器：

   $ oc get sinkbindings.sources.knative.dev bind-heartbeat -oyaml

   输出示例

   spec:
     sink:
       ref:
         apiVersion: serving.knative.dev/v1
         kind: Service
         name: event-display
         namespace: default
     subject:
       apiVersion: batch/v1
       kind: Job
       namespace: default
       selector:
         matchLabels:
           app: heartbeat-cron

1. 输入命令：

   $ oc get pods

2. 输入命令：

   $ oc logs $(oc get pod -o name | grep event-display) -c user-container

   输出示例

   ☁️  cloudevents.Event
   Validation: valid
   Context Attributes,
     specversion: 1.0
     type: dev.knative.eventing.samples.heartbeat
     source: https://knative.dev/eventing-contrib/cmd/heartbeats/#event-test/mypod
     id: 2b72d7bf-c38f-4a98-a433-608fbcdd2596
     time: 2019-10-18T15:23:20.809775386Z
     contenttype: application/json
   Extensions,
     beats: true
     heart: yes
     the: 42
   Data,
     {
       "id": 1,
       "label": ""
     }

流程

1. 要检查接收器绑定是否已正确设置，请创建一个 Knative 事件显示服务或事件 sink，在日志中转储传入的信息：

   $ kn service create event-display --image quay.io/openshift-knative/showcase

2. 创建将事件定向到该服务的接收器绑定实例：

   $ kn source binding create bind-heartbeat --subject Job:batch/v1:app=heartbeat-cron --sink ksvc:event-display

3. 创建 CronJob 对象。

   1. 创建 cron 任务 YAML 文件：

      Cron Job YAML 文件示例

      apiVersion: batch/v1
      kind: CronJob
      metadata:
        name: heartbeat-cron
      spec:
        # Run every minute
        schedule: "* * * * *"
        jobTemplate:
          metadata:
            labels:
              app: heartbeat-cron
              bindings.knative.dev/include: "true"
          spec:
            template:
              spec:
                restartPolicy: Never
                containers:
                  - name: single-heartbeat
                    image: quay.io/openshift-knative/heartbeats:latest
                    args:
                      - --period=1
                    env:
                      - name: ONE_SHOT
                        value: "true"
                      - name: POD_NAME
                        valueFrom:
                          fieldRef:
                            fieldPath: metadata.name
                      - name: POD_NAMESPACE
                        valueFrom:
                          fieldRef:
                            fieldPath: metadata.namespace

      重要

      要使用接收器绑定，您必须手动在 Knative CR 中添加 bindings.knative.dev/include=true 标签。

      例如，要将此标签添加到 CronJob CR，请将以下行添加到 Job CR YAML 定义中：

        jobTemplate:
          metadata:
            labels:
              app: heartbeat-cron
              bindings.knative.dev/include: "true"

   2. 创建 cron job：

      $ oc apply -f <filename>

4. 输入以下命令并检查输出，检查是否正确映射了控制器：

   $ kn source binding describe bind-heartbeat

   输出示例

   Name:         bind-heartbeat
   Namespace:    demo-2
   Annotations:  sources.knative.dev/creator=minikube-user, sources.knative.dev/lastModifier=minikub ...
   Age:          2m
   Subject:
     Resource:   job (batch/v1)
     Selector:
       app:      heartbeat-cron
   Sink:
     Name:       event-display
     Resource:   Service (serving.knative.dev/v1)
   
   Conditions:
     OK TYPE     AGE REASON
     ++ Ready     2m

流程

1. 创建 Knative 服务以用作接收器：

   1. 在 Developer 视角中，导航到 +Add YAML。

   2. 复制 YAML 示例：

      apiVersion: serving.knative.dev/v1
      kind: Service
      metadata:
        name: event-display
      spec:
        template:
          spec:
            containers:
              - image: quay.io/openshift-knative/showcase

   3. 点 Create。

2. 创建用作事件源的 CronJob 资源，并每分钟发送一个事件。

   1. 在 Developer 视角中，导航到 +Add YAML。

   2. 复制 YAML 示例：

      apiVersion: batch/v1
      kind: CronJob
      metadata:
        name: heartbeat-cron
      spec:
        # Run every minute
        schedule: "*/1 * * * *"
        jobTemplate:
          metadata:
            labels:
              app: heartbeat-cron
              bindings.knative.dev/include: true 1
          spec:
            template:
              spec:
                restartPolicy: Never
                containers:
                  - name: single-heartbeat
                    image: quay.io/openshift-knative/heartbeats
                    args:
                    - --period=1
                    env:
                      - name: ONE_SHOT
                        value: "true"
                      - name: POD_NAME
                        valueFrom:
                          fieldRef:
                            fieldPath: metadata.name
                      - name: POD_NAMESPACE
                        valueFrom:
                          fieldRef:
                            fieldPath: metadata.namespace

      1

      确保包含 bindings.knative.dev/include: true 标签。OpenShift Serverless 的默认命名空间选择行为使用包含模式。

   3. 点 Create。

3. 在与上一步中创建的服务相同的命名空间中创建接收器绑定，或您要将事件发送到的任何其他接收器。

   1. 在 Developer 视角中，导航到 +Add Event Source。此时会显示 Event Sources 页面。
   2. 可选：如果您的事件源有多个供应商，请从 Providers 列表中选择所需的供应商，以过滤供应商的可用事件源。

   3. 选择 Sink Binding，然后单击 Create Event Source。此时会显示 Create Event Source 页面。

      注意

      您可以使用 Form view 或 YAML view 配置 Sink Binding 设置，并可以在两者间切换。在不同视图间切换时数据会被保留。

   4. 在 apiVersion 字段中，输入 batch/v1。

   5. 在 Kind 字段中，输入 Job。

      注意

      OpenShift Serverless sink 绑定不支持 CronJob kind，因此 Kind 字段必须以 cron 任务创建的 Job 对象为目标，而不是 cron 作业对象本身。

   6. 在 Target 部分中，选择您的事件 sink。这可以是 Resource 或一个 URI ：

      1. 选择 Resource 使用频道、代理或服务作为事件源的事件 sink。在本例中，上一步中创建的 event-display 服务被用作目标 资源。
      2. 选择 URI，以指定事件要路由到的 Uniform Resource Identifier (URI)。

   7. 在 Match labels 部分：

      1. 在 Name 字段中输入 app。

      2. 在 Value 字段中输入 heartbeat-cron。

         注意

         使用带有接收器绑定的 cron 任务时，需要标签选择器，而不是资源名称。这是因为，Cron Job 创建的作业没有可预测的名称，并在名称中包含随机生成的字符串。例如，hearthbeat-cron-1cc23f.

   8. 点 Create。

1. 在 Developer 视角中，导航到 Topology。

2. 查看接收器绑定、接收器和心跳 cron 任务。

   
3. 观察在添加了接收器绑定后 cron 任务正在注册成功的作业。这意味着接收器绑定成功重新配置由 cron 任务创建的作业。

4. 浏览 event-display 服务，以查看 heartbeats cron 作业生成的事件。

   

流程

1. 在作为 Service MeshMemberRoll 成员的命名空间中创建一个 Service。

   apiVersion: serving.knative.dev/v1
   kind: Service
   metadata:
     name: event-display
     namespace: <namespace> 1
   spec:
     template:
       metadata:
         annotations:
           sidecar.istio.io/inject: "true" 2
           sidecar.istio.io/rewriteAppHTTPProbers: "true"
       spec:
         containers:
         - image: quay.io/openshift-knative/showcase

   1

   作为 ServiceMeshMemberRoll 成员的命名空间。

   2

   将 Service Mesh sidecar 注入 Knative 服务 pod。

2. 应用 Service 资源。

   $ oc apply -f <filename>

3. 创建 SinkBinding 资源。

   apiVersion: sources.knative.dev/v1
   kind: SinkBinding
   metadata:
     name: bind-heartbeat
     namespace: <namespace> 1
   spec:
     subject:
       apiVersion: batch/v1
       kind: Job 2
       selector:
         matchLabels:
           app: heartbeat-cron
   
     sink:
       ref:
         apiVersion: serving.knative.dev/v1
         kind: Service
         name: event-display

   1

   作为 ServiceMeshMemberRoll 成员的命名空间。

   2

   在本例中，任何带有标签 app: heartbeat-cron 的作业都绑定到事件 sink。

4. 应用 SinkBinding 资源。

   $ oc apply -f <filename>

5. 创建 CronJob ：

   apiVersion: batch/v1
   kind: CronJob
   metadata:
     name: heartbeat-cron
     namespace: <namespace> 1
   spec:
     # Run every minute
     schedule: "* * * * *"
     jobTemplate:
       metadata:
         labels:
           app: heartbeat-cron
           bindings.knative.dev/include: "true"
       spec:
         template:
           metadata:
             annotations:
               sidecar.istio.io/inject: "true" 2
               sidecar.istio.io/rewriteAppHTTPProbers: "true"
           spec:
             restartPolicy: Never
             containers:
               - name: single-heartbeat
                 image: quay.io/openshift-knative/heartbeats:latest
                 args:
                   - --period=1
                 env:
                   - name: ONE_SHOT
                     value: "true"
                   - name: POD_NAME
                     valueFrom:
                       fieldRef:
                         fieldPath: metadata.name
                   - name: POD_NAMESPACE
                     valueFrom:
                       fieldRef:
                         fieldPath: metadata.namespace

   1

   作为 ServiceMeshMemberRoll 成员的命名空间。

   2

   将 Service Mesh sidecar 注入 CronJob pod。

6. 应用 CronJob 资源。

   $ oc apply -f <filename>

1. 输入以下命令：

   $ oc get pods

2. 输入以下命令：

   $ oc logs $(oc get pod -o name | grep event-display) -c user-container

   输出示例

   ☁️  cloudevents.Event
   Validation: valid
   Context Attributes,
     specversion: 1.0
     type: dev.knative.eventing.samples.heartbeat
     source: https://knative.dev/eventing/test/heartbeats/#event-test/mypod
     id: 2b72d7bf-c38f-4a98-a433-608fbcdd2596
     time: 2019-10-18T15:23:20.809775386Z
     contenttype: application/json
   Extensions,
     beats: true
     heart: yes
     the: 42
   Data,
     {
       "id": 1,
       "label": ""
     }

流程

1. 在 Developer 视角中，导航到 +Add Event Source。此时会显示 Event Sources 页面。
2. 选择 Container Source，然后点 Create Event Source。此时会显示 Create Event Source 页面。

3. 使用 Form view 或 YAML 视图配置 Container Source 设置：

   注意

   您可以在 Form view 和 YAML view 间进行切换。在不同视图间切换时数据会被保留。

   1. 在 Image 字段中，输入您要在由容器源创建的容器中运行的镜像的 URI。
   2. 在 Name 字段中输入镜像的名称。
   3. 可选：在 Arguments 参数字段中，输入要传递给容器的任何参数。
   4. 可选：在 Environment variables 字段中，添加容器中要设置的任何环境变量。

   5. 在 Target 部分中，选择您的事件 sink。这可以是 Resource 或一个 URI ：

      1. 选择 Resource 使用频道、代理或服务作为事件源的事件 sink。
      2. 选择 URI，以指定事件要路由到的 Uniform Resource Identifier (URI)。
4. 配置完容器源后，点 Create。

流程

1. 在作为 Service MeshMemberRoll 成员的命名空间中创建一个 Service。

   apiVersion: serving.knative.dev/v1
   kind: Service
   metadata:
     name: event-display
     namespace: <namespace> 1
   spec:
     template:
       metadata:
         annotations:
           sidecar.istio.io/inject: "true" 2
           sidecar.istio.io/rewriteAppHTTPProbers: "true"
       spec:
         containers:
         - image: quay.io/openshift-knative/showcase

   1

   作为 ServiceMeshMemberRoll 成员的命名空间。

   2

   将 Service Mesh sidecar 注入 Knative 服务 pod。

2. 应用 Service 资源。

   $ oc apply -f <filename>

3. 在作为 ServiceMeshMemberRoll 和 sink 成员的命名空间中创建 ContainerSource 对象，设置为 event-display。

   apiVersion: sources.knative.dev/v1
   kind: ContainerSource
   metadata:
     name: test-heartbeats
     namespace: <namespace> 1
   spec:
     template:
       metadata: 2
         annotations:
           sidecar.istio.io/inject: "true"
           sidecar.istio.io/rewriteAppHTTPProbers: "true"
       spec:
         containers:
           - image: quay.io/openshift-knative/heartbeats:latest
             name: heartbeats
             args:
               - --period=1s
             env:
               - name: POD_NAME
                 value: "example-pod"
               - name: POD_NAMESPACE
                 value: "event-test"
     sink:
       ref:
         apiVersion: serving.knative.dev/v1
         kind: Service
         name: event-display

   1

   命名空间是 ServiceMeshMemberRoll 的一部分。

   2

   启用 Service Mesh 与 ContainerSource 对象集成。

4. 应用 ContainerSource 资源。

   $ oc apply -f <filename>

1. 输入以下命令：

   $ oc get pods

2. 输入以下命令：

   $ oc logs $(oc get pod -o name | grep event-display) -c user-container

   输出示例

   ☁️  cloudevents.Event
   Validation: valid
   Context Attributes,
     specversion: 1.0
     type: dev.knative.eventing.samples.heartbeat
     source: https://knative.dev/eventing/test/heartbeats/#event-test/mypod
     id: 2b72d7bf-c38f-4a98-a433-608fbcdd2596
     time: 2019-10-18T15:23:20.809775386Z
     contenttype: application/json
   Extensions,
     beats: true
     heart: yes
     the: 42
   Data,
     {
       "id": 1,
       "label": ""
     }