CronJob Pod调度问题：需实现基于Redis返回值的Pod自动终止

AI 小北

2026-8-11

解决CronJob重复创建Pod及自定义Pod终止逻辑的方案

一、阻止CronJob并发创建Pod

通过配置CronJob的并发策略，确保只有当已有Pod终止后，才会创建新的Pod：

修改CronJob的YAML配置，添加concurrencyPolicy: Forbid（如果有正在运行的Pod，CronJob会跳过本次调度），或者concurrencyPolicy: Replace（用新Pod替换正在运行的旧Pod）。示例配置如下：

apiVersion: batch/v1
kind: CronJob
metadata:
  name: redis-data-fetcher
spec:
  schedule: "*/2 * * * *"
  concurrencyPolicy: Forbid  # 核心配置：禁止并发运行Pod
  jobTemplate:
    spec:
      template:
        spec:
          containers:
          - name: redis-fetcher
            image: your-custom-python-image:tag
            command: ["python", "/path/to/your/script.py"]
          restartPolicy: Never  # 避免Pod因脚本退出自动重启

二、实现Pod自定义终止逻辑

修改你的Python脚本，加入Redis读取后的判断逻辑，控制Pod的退出时机：

import redis
import time

def get_redis_data():
    # 根据你的Redis实例配置修改连接参数
    redis_client = redis.Redis(host="redis-service", port=6379, db=0)
    # 替换为你实际的Redis数据读取逻辑
    raw_data = redis_client.get("target-key")
    return raw_data.decode("utf-8") if raw_data else "Empty"

if __name__ == "__main__":
    result = get_redis_data()
    if result == "Empty":
        print("收到Empty响应，立即退出")
        exit(0)
    else:
        print(f"收到数据：{result}，等待10秒后退出")
        time.sleep(10)
        exit(0)