如何在 Django 中添加另一个数据库服务器节点

How to add another database server node in Django

我在一台机器上 运行 有 2 个数据库。我的问题是如何添加更多数据库服务器以及我想使用 django 分片所以我如何根据用户从两个数据库中分片我的数据意味着用户 1 数据来自第一台服务器上的 db1 和 db2 用户 2 的数据在另一个

您需要在设置中定义路由器:

DATABASE_ROUTERS = ['routers.routers.ModelDatabaseRouter']

在路由器中创建文件路由器:

class ModelDatabaseRouter(object):
    """Allows each model to set its own destiny"""

    def db_for_read(self, model, **hints):
        # Specify target database with field in_db in model's Meta class
        if hasattr(model._meta, 'in_db'):
            return model._meta.in_db
        return None

    def db_for_write(self, model, **hints):
        # Specify target database with field in_db in model's Meta class
        if hasattr(model._meta, 'in_db'):
            return model._meta.in_db        
        return None

    def allow_syncdb(self, db, model):      
        # Specify target database with field in_db in model's Meta class
        if hasattr(model._meta, 'in_db'):
            if model._meta.in_db == db:
                return True
            else:
                return False
        else:
            # Random models that don't specify a database can only go to 'default'
            if db == 'default':
                return True
            else:
                return False

(来自 )https://djangosnippets.org/snippets/2687/

现在您可以像这样在模型中定义数据库:

class YourClass(models.Model):
    name = models.CharField(primary_key=True, max_length=50)
    creation_time = models.DateTimeField()

    class Meta:
        in_db = 'api'  <-- THIS

数据库必须在设置中定义:

DATABASES = {
    'default': {
        'ENGINE': 'django.db.backends.mysql',
        'NAME': 'XXXXX',
        'USER': 'XXXXX',
        'PASSWORD': 'XXXXXX',
        'HOST': '127.0.0.1',
        'PORT': '3306',
    },
    'api': {
        'ENGINE': 'django.db.backends.mysql',
        'NAME': 'xxxx',
        'USER': 'xxxx',
        'PASSWORD': 'xxxxxx',
        'HOST': '127.0.0.1',
        'PORT': '3306',
    }
}