妙招！利用preStop 回调函数清理job运行后的残留文件

2022-11-01 20:16:37

在 Kubernetes 中管理 Job 产生的临时文件

Kubernetes 提供了一种称为 Job 的特殊工作负载，用于运行有限次数的任务。在 Job 运行期间，可能会产生临时文件。这些文件通常无用，并且可能会占用大量的存储空间。本文将探讨在 Job 运行结束后删除这些临时文件的最佳实践。

使用 preStop 回调函数

Kubernetes 提供了一个 preStop 钩子，允许我们在 Job 运行结束后执行自定义操作。我们可以利用这个钩子来删除 Job 运行产生的临时文件。

以下是一个示例，说明如何使用 preStop 回调函数删除文件 /tmp/foo：

apiVersion: batch/v1
kind: Job
metadata:
  name: my-job
spec:
  template:
    spec:
      containers:
      - name: my-container
        image: my-image
        command: ["sh", "-c", "touch /tmp/foo"]
        preStop:
          exec:
            command: ["rm", "-f", "/tmp/foo"]

Client-Go 删除 Job 时的注意事项

在使用 client-go 删除 Job 时，需要注意一个潜在问题：如果 Job 正在运行，则无法将其删除。

// 等待 Job 完成
err := client.BatchV1().Jobs("default").Get(context.Background(), "my-job", metav1.GetOptions{}).WaitUntilComplete(context.Background(), &metav1.Condition{Type: batch.JobComplete, Status: metav1.ConditionTrue})
if err != nil {
    // 处理错误
}

// 删除 Job
err = client.BatchV1().Jobs("default").Delete(context.Background(), "my-job", metav1.DeleteOptions{})
if err != nil {
    // 处理错误
}