2

我正在使用Django 2.x和Celery 4.3.x

在我的Django应用程序中，我使用dotenv从.env文件中提供环境变量并加载环境变量，我在manage.py和wsgy.py文件中有以下脚本

env_file = os.path.join(os.path.dirname(os.path.realpath(__file__)), '.env')
dotenv.read_dotenv(env_file)

环境变量具有插件使用的 AWS 凭证，以使用SESanymail发送邮件。

现在，我正在使用 Celery 任务发送电子邮件并使用命令行运行 celery worker

celery -A myapp worker -l debug

工作人员正在运行，但是在发送电子邮件时，它在 celery 任务中出现错误，因为

ERROR/ForkPoolWorker-2] An error occurred (AccessDenied) when calling 
the SendRawEmail operation: User `arn:aws:iam::user_id:user/my-laptop` is not 
authorized to permorm this action...

似乎试图与我的笔记本电脑的用户连接，而不是使用.env文件中定义的凭据。

如何使用该.env文件将环境文件提供给 Celery 工作人员？

4

2 回答 2

1

通过在celery config文件中加载环境变量解决

celery.py

env_file = os.path.join(os.path.dirname(os.path.dirname(os.path.realpath(__file__))), '.env')
dotenv.read_dotenv(env_file)
于 2019-08-23T07:53:27.030 回答
0

不知道如何使用 dotenv 来做到这一点，但我使用python-decouple.env在一些 celery 任务中从文件中提取参数。

from decouple import config

AUTH_USER = config('AUTH_USER')
AUTH_PASS = config('AUTH_PASS')
于 2019-08-16T14:08:06.097 回答