Python Celery - 权限问题 - 无法从下载任务上传文件

Question

我有一个 Celery 任务，其工作是将文件下载到本地目录，然后在下载完成后上传到 S3 存储桶。

我的问题是，最近更新了工作人员，在访问要上传的文件夹时出现权限被拒绝错误。除了从脚本方法到基于类的实现之外，代码基本上没有改变。

我做了一个任务来创建目录，只需要一个方法调用：

os.mkdirs(path, 777)

它会创建具有300权限的目录

尽管如此

CELERYD_USERS='ubuntu'
CELERYD_GROUP='ubuntu'
CELERYD_CREATE_DIRS=1

在配置中。

根据docs，最后一个选项允许 celery 创建一个由上面指定的用户/组拥有的目录。发生了很多事情，但没有提及权限。

有没有办法解决这个问题？

Answer 1

CELERY_CREATE_DIR 只告诉 celery 创建它的操作目录：

始终创建目录（日志目录和 pid 文件目录）。默认只在没有设置自定义日志文件/pidfile 时创建目录。

我相信您的问题与os.mkdirs 有关。根据os.mkdir doc，mode在您的系统上可能会被忽略，您需要使用os.chmod更改模式。