3.4. JobSink

流程

• 读取 事件 文件，并使用任何 CloudEvents JSON deserializer 进行反序列化。以下示例演示了如何使用 CloudEvents Go SDK 读取和处理事件：

  package mytask
  
  import (
      "encoding/json"
      "fmt"
      "os"
  
      cloudevents "github.com/cloudevents/sdk-go/v2"
  )
  
  func handleEvent() error {
      eventBytes, err := os.ReadFile("/etc/jobsink-event/event")
      if err != nil {
          return err
      }
  
      event := &cloudevents.Event{}
      if err := json.Unmarshal(eventBytes, event); err != nil {
          return err
      }
  
      fmt.Println(event)
  
      return nil
  }

流程

• 在容器定义中，包括 volumeMounts 配置并根据需要设置。

  apiVersion: sinks.knative.dev/v1alpha1
  kind: JobSink
  metadata:
    name: job-sink-custom-mount-path
  spec:
    job:
      spec:
        completions: 1
        parallelism: 1
        template:
          spec:
            restartPolicy: Never
            containers:
              - name: main
                image: docker.io/library/bash:5
                command: [ "bash" ]
                args:
                  - -c
                  - echo "Hello world!" && sleep 5
  
                # The event will be available in a file at `/etc/custom-path/event`
                volumeMounts:
                  - name: "jobsink-event"
                    mountPath: "/etc/custom-path"
                    readOnly: true

流程

• 在定义中，将 ttlSecondsAfterFinished 的值设置为所需的数量。

  ttlSecondsAfterFinished 设置为 600 的示例

  apiVersion: sinks.knative.dev/v1alpha1
  kind: JobSink
  metadata:
    name: job-sink-example
  spec:
    job:
      spec:
        ttlSecondsAfterFinished: 600

流程

• 通过在 JobSink 定义中包含错误模拟命令来触发 FailJob 操作。

  JobSink 失败示例

  apiVersion: sinks.knative.dev/v1alpha1
  kind: JobSink
  metadata:
    name: job-sink-failure
  spec:
    job:
      metadata:
        labels:
          my-label: my-value
      spec:
        completions: 12
        parallelism: 3
        template:
          spec:
            restartPolicy: Never
            containers:
              - name: main
                image: docker.io/library/bash:5
                command: [ "bash" ]        # example command simulating a bug which triggers the FailJob action
                args:
                  - -c
                  - echo "Hello world!" && sleep 5 && exit 42
        backoffLimit: 6
        podFailurePolicy:
          rules:
            - action: FailJob
              onExitCodes:
                containerName: main      # optional
                operator: In             # one of: In, NotIn
                values: [ 42 ]
            - action: Ignore             # one of: Ignore, FailJob, Count
              onPodConditions:
                - type: DisruptionTarget   # indicates Pod disruption