用于生产者和工人模型的 Django Celery 数据库

Question

我想开发一个使用 Django 作为 Fronted 和 Celery 来做后台工作的应用程序。 现在，有时不同机器上的 Celery 工作人员需要访问我的 django 前端机器（两个不同的服务器）的数据库。 他们需要了解一些实时的东西，并运行 django 应用程序，

python manage.py celeryd 

他们需要访问包含所有可用模型的数据库。

我必须通过直接连接访问我的 MySQL 数据库吗？因此，我必须允许用户“my-django-app”不仅从我的前端计算机上的本地主机访问，而且还从我的其他工作服务器 ips 访问？

这是“正确”的方式，还是我错过了一些东西？只是认为它并不真正安全（没有 ssl），但也许这就是它必须的方式。

感谢您的回复！

Answer 1

他们需要访问数据库。该访问将通过数据库后端进行，该后端可以是 Django 或 来自第三方。

我在 Django 站点的 settings.py 中所做的一件事是从 /etc 中的文件加载数据库访问信息。这样，每台计算机的访问设置（数据库主机、端口、用户名、密码）都可以不同，并且密码等敏感信息不在我的项目存储库中。您可能希望以类似的方式限制对工作人员的访问，让他们使用不同的用户名进行连接。

您还可以通过环境变量传入数据库连接信息，甚至只是配置文件的键或路径，并在 settings.py 中处理它。

例如，以下是我提取数据库配置文件的方法：

g = {}
dbSetup = {}
execfile(os.environ['DB_CONFIG'], g, dbSetup)
if 'databases' in dbSetup:
    DATABASES = dbSetup['databases']
else:
    DATABASES = {
        'default': {
            'ENGINE': 'django.db.backends.mysql',
            # ...
        }
    }

不用说，您需要确保除数据库管理员和 Django 本身之外的任何用户都无法访问 DB_CONFIG 中的文件。默认情况下，Django 应该引用开发人员自己的测试数据库。使用 ast 模块代替 execfile 可能还有更好的解决方案，但我还没有研究过。

我做的另一件事是使用单独的用户来执行数据库管理任务而不是其他任务。在我的 manage.py 中，我添加了以下序言：

# Find a database configuration, if there is one, and set it in the environment.
adminDBConfFile = '/etc/django/db_admin.py'
dbConfFile = '/etc/django/db_regular.py'
import sys
import os
def goodFile(path):
    return os.path.isfile(path) and os.access(path, os.R_OK)
if len(sys.argv) >= 2 and sys.argv[1] in ["syncdb", "dbshell", "migrate"] \
    and goodFile(adminDBConfFile):
    os.environ['DB_CONFIG'] = adminDBConfFile
elif goodFile(dbConfFile):
    os.environ['DB_CONFIG'] = dbConfFile

/etc/django/db_regular.py 中的配置适用于只能访问 Django 数据库的用户SELECT、INSERT、UPDATE 和 DELETE，/etc/django/db_admin.py 适用于具有这些权限以及 CREATE、DROP、INDEX、ALTER 和 LOCK TABLES 权限的用户。 （migrate 命令来自 South。）这为我提供了一些针对 Django 代码的保护在运行时扰乱我的模式，并且它限制了 SQL 注入攻击可能造成的损害（尽管您仍然应该检查和过滤所有用户输入）。

这并不能解决您的具体问题，但它可能会为您提供一些想法，帮助您根据您的目的优化 Django 的数据库访问设置。