使用Django简化分片

pip install django-sharding

INSTALLED_APPS = [
    # ...
    'django_sharding',
    # ...
]

DATABASES = {
    'default': {
        'ENGINE': 'django_sharding',
        'SHARD_GROUPS': {
            'default': {
                'SHARDS': [
                    {
                        'NAME': 'db0',
                        'WRITE': True,
                        'BACKEND': 'django.db.backends.postgresql',
                        'HOST': 'localhost',
                        'PORT': '5432',
                        'USER': 'user',
                        'PASSWORD': 'password',
                    },
                    {
                        'NAME': 'db1',
                        'BACKEND': 'django.db.backends.postgresql',
                        'HOST': 'localhost',
                        'PORT': '5432',
                        'USER': 'user',
                        'PASSWORD': 'password',
                    },
                ],
                'DATABASE_MODEL': 'sharded',
            },
        },
    },
}

from django_sharding import get_shard

# 获取分片实例
shard = get_shard('default')

# 使用分片实例进行数据操作
shard.create_model(MyModel)
shard.add(MyModel(id=1, name='John'))
shard.commit()

MIDDLEWARE = [
    # ...
    'django_sharding.middleware.QueryLogMiddleware',
    # ...
]