celery 日志打印问题

[echo1248]

[program:fba_celery_beat]
directory=/fba/backend
command=/usr/local/bin/celery -A app.task.celery beat --loglevel=INFO
user=root
autostart=true
autorestart=true
startretries=5
redirect_stderr=true
stdout_logfile=/var/log/fba/fba_celery_beat.log
stdout_logfile_maxbytes=5MB
stdout_logfile_backups=5

/var/log/fba/fba_celery_beat.log，启动后日志不持续更新，只有启动成功的打印日志。后续的日志不更新

[wu-clan]

线上演示环境如下所示：

[echo1248]

app/task/utils/schedulers.py
282 行 lock_key = f'{settings.CELERY_REDIS_PREFIX}:beat_lock'
是否需要调整为 lock_key = f'{settings.ENVIRONMENT}_{settings.CELERY_REDIS_PREFIX}:beat_lock'

[wu-clan]

当程序停止时，锁会被释放

这是您发现的影响日志的原因吗？

[echo1248]

同一台机器上面，部署了两套独立的服务，schedule生成会受lock的影响。
日志是另外的原因，改supervisor的配置文件，把相同配置抽出来放到一个common模版中，会有影响，恢复成原来样子就正常了。

[echo1248]

也可以直接修改CELERY_REDIS_PREFIX的配置来区分
另外建议 添加一个 CELERY_RABBITMQ_VHOST的配置

[wu-clan]

我会稍后进行更新

[wu-clan]

我回想了一下，这个前缀并不能更新，当启动多个 worker 时，为了确保任务不被重复执行，分布式锁是唯一的，不然任务会重复执行