Golang如何在Kubernetes中实现Job与CronJob任务_Golang Kubernetes Job任务实践

package main
<p>import (
"bufio"
"fmt"
"os"
"path/filepath"
)</p><p>func main() {
// 获取命令行传入的文件路径
if len(os.Args) < 2 {
fmt.Println("usage: job count-lines <file-path>")
os.Exit(1)
}</p><pre class="brush:php;toolbar:false;"><pre class="brush:php;toolbar:false;">filePath := os.Args[1]
file, err := os.Open(filePath)
if err != nil {
    fmt.Printf("failed to open file: %v\n", err)
    os.Exit(1)
}
defer file.Close()

scanner := bufio.NewScanner(file)
lines := 0
for scanner.Scan() {
    lines++
}

if err := scanner.Err(); err != nil {
    fmt.Printf("error reading file: %v\n", err)
    os.Exit(1)
}

fmt.Printf("File %s has %d lines\n", filepath.Base(filePath), lines)
os.Exit(0) // 成功退出

FROM golang:alpine AS builder
WORKDIR /app
COPY . .
RUN go build -o counter .
<p>FROM alpine:latest
RUN apk --no-cache add ca-certificates
WORKDIR /root/
COPY --from=builder /app/counter .
COPY data.txt .  # 假设任务处理此文件</p><p>CMD ["./counter", "data.txt"]

docker build -t your-repo/line-counter:v1 .
docker push your-repo/line-counter:v1

apiVersion: batch/v1
kind: Job
metadata:
  name: line-count-job
spec:
  template:
    spec:
      containers:
      - name: counter
        image: your-repo/line-counter:v1
        imagePullPolicy: IfNotPresent
      restartPolicy: Never
  backoffLimit: 4

kubectl apply -f job.yaml

kubectl logs job/line-count-job

apiVersion: batch/v1
kind: CronJob
metadata:
  name: daily-line-count
spec:
  schedule: "0 0 * * *"  # 每天零点执行
  jobTemplate:
    spec:
      template:
        spec:
          containers:
          - name: counter
            image: your-repo/line-counter:v1
            imagePullPolicy: IfNotPresent
          restartPolicy: Never
  successfulJobsHistoryLimit: 3
  failedJobsHistoryLimit: 1

kubectl apply -f cronjob.yaml
kubectl get cronjobs
kubectl get jobs --watch