如何在已经守护的 Celery 进程中更改我的CELERY_BROKER_URL?

Question

我正在使用 Supervisord 守护我的 Celery 工作人员。问题是我的CELERY_BROKER_URL有错别字，并且工作人员没有正确连接到 RabbitMQ。

当我运行celery -A mysite report时，它会显示旧的环境变量。

我的/etc/supervisor/conf.d/celery.conf文件不包含环境变量：

[program:celery]
command=/webapps/mysite/scripts/celery/celery_start
autostart=true
autorestart=true
user=myuser
stdout_logfile=/webapps/mysite/logs/celery.log
redirect_stderr = true

环境变量是通过我的虚拟环境在celery_start脚本中选取的：

#!/bin/sh
DJANGODIR=/webapps/mysite/mysite
# Activate the virtual environment.
cd $DJANGODIR
. /webapps/mysite/bin/activate
. /webapps/mysite/bin/postactivate
# Programs meant to be run under supervisor should not daemonize themselves
# (do not use --daemon).
exec celery -A mysite worker -E -l info --concurrency=2

当我在激活环境后检查CELERY_BROKER_URL环境变量时，它是正确的。我已经尝试了supervisorctl restart celery它不选取新的环境变量(celery -A mysite report显示旧CELERY_BROKER_URL(。我已经尝试了supervisorctl shutdown然后supervisord它也不会选择新的环境变量。

当我运行ps aux | grep 'celery worker'时，我什么也没看到，大概是因为 Celery 是由 Supervisor 守护程序化的，所以我不确定有什么方法可以完全破坏当前的 Celery 进程。

无论如何，感觉芹菜没有选择新的环境变量。我怎样才能做到这一点？

[编辑] 我在settings.py中的芹菜设置如下：

# Celery settings.
CELERY_BROKER_URL = os.environ.get(
'BROKER_URL', 'amqp://guest:guest@127.0.0.1//')
CELERY_TASK_SOFT_TIME_LIMIT = 60
CELERY_RESULT_BACKEND = 'django-db'

我的mysite/celery.py文件是：

from __future__ import absolute_import, unicode_literals
import os
from celery import Celery
# set the default Django settings module for the 'celery' program.
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'settings.local')
APP = Celery('mysite')
# Using a string here means the worker doesn't have to serialize
# the configuration object to child processes.
# - namespace='CELERY' means all celery-related configuration keys
#   should have a `CELERY_` prefix.
APP.config_from_object('django.conf:settings', namespace='CELERY')
# Load task modules from all registered Django app configs.
APP.autodiscover_tasks()

@APP.task(bind=True)
def debug_task(self):
print('Request: {0!r}'.format(self.request))

Answer 1

事实证明，由于某种原因，我为我的经纪人使用了一个密码，该密码包含无效字符。

密码#qahrKscbW#3!HkMJg#jFcyaOR7HtK%j08Jt$yY2。

发生的事情是我的broker_url无效，因此它默认恢复为ampq://guest:password而不是ampq://myuser:#qahrKscbW#3!HkMJg#jFcyaOR7HtK%j08Jt$yY2@localhost/mysite。

我将密码更改为仅使用字母数字字符，并且它起作用了。