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