3.4. JobSink

手順

• event ファイルを読み取り、任意の CloudEvents JSON デシリアライザーを使用してデシリアライズします。次の例は、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