Celery 任务在本地运行时正常关闭时重新排队到代理中，但尽管配置相同，但在 kubernetes 中丢失

问题描述

我在 k8 pod 中运行了一个 celery。这是我的芹菜清单

apiVersion: apps/v1
kind: Deployment
Metadata:
  name: celery
  labels:
    deployment: celery
spec:
  replicas: 2
  selector:
    matchLabels:
      pod: celery
  template:
    Metadata:
      labels:
        pod: celery
    spec:
      containers:
        - name: celery
          image: local_celery:latest
          imagePullPolicy: Never
          command: ['celery','-A','proj','worker','-E','-l','info',]
          resources:
            limits:
              cpu: 50m
            requests:
              cpu: 50m

      terminationGracePeriodSeconds: 25

我在 django settings.py 中的 Celery 配置是

CELERY_TASK_ACKS_LATE = True
CELERY_WORKER_PREFETCH_MULTIPLIER = 1
CELERY_broKER_URL = 'redis://redis:6379'
CELERY_RESULT_BACKEND = 'django-db'
CELERY_WORKER_CONCURRENCY=1
CEELERY_TASK_REJECT_ON_WORKER_LOST=True

当我使用 celery 和 redis 作为消息代理运行一个简单的 django 应用程序时，当我执行 ctrl-C 以启动工作人员的热关机时，我的任务会重新排队到代理中。但是当同一个应用程序部署到 kubernetes 时，celery、django 和 redis 运行在 3 个不同的 pod 中 当 celery pod 正常终止时，我的任务不会重新排队回到 redis。我不明白为什么？在这两种情况下，我的 celery 设置都没有改变。

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）