django-horizon 1.1.2

水平数据库组和元数据存储

HORIZONTAL_CONFIG = {
    'GROUPS': {
        'group1': {  # The name of database horizontal partitioning group
            'DATABASES': {
                1: {
                    'write': 'member1-primary',
                    'read': ['member1-replica-1', 'member1-replica-2'],  # Pick randomly by router
                },
                2: {
                    'write': 'member2-primary',
                    'read': ['member2-replica'],
                },
                3: {
                    'write': 'a3',  # Used by 'read' too
                },
            },
            'PICKABLES': [2, 3],  # Group member keys to pick new database
        },
    },
    'METADATA_MODEL': 'app.HorizontalMetadata',  # Metadata store for horizontal partition key and there database
}

数据库路由

DATABASE_ROUTERS = (
    'horizon.routers.HorizontalRouter',
    ...
)

元数据存储

from horizon.models import AbstractHorizontalMetadata

class HorizontalMetadata(AbstractHorizontalMetadata):
    pass

在示例中，元数据存储保存以下内容。

• group：水平分区的组名称。

• key：确定表记录在水平分区组中的分布。

• index：在水平分区组中选择的数据库索引。

分片模型

from django.conf import settings

from horizon.manager import HorizontalManager  # For Django<1.10
from horizon.models import AbstractHorizontalModel


class SomeLargeModel(AbstractHorizontalModel):
    user = models.ForeignKey(
        settings.AUTH_USER_MODEL,
        on_delete=models.DO_NOTHING,
        db_constraint=False,  # May be using anothor database
    )
    ...

    objects = HorizontalManager()  # For Django<1.10

    class Meta(object):
        horizontal_group = 'group1'  # Group name
        horizontal_key = 'user'  # Field name to use group key

在许多情况下，使用UUIDField字段作为id。默认情况下，AbstractHorizontalModel使用UUIDField作为主键字段。

使用模型

from django.contrib.auth import get_user_model


user_model = get_user_model()
user = user_model.objects.get(pk=1)

# Get by foreign instance
SomeLargeModel.objects.filter(uses=user)

# Get by foreign id
SomeLargeModel.objects.filter(uses_id=user.id)

模型限制

• 当未指定水平键字段进行过滤时，会发生django.db.utils.IntegrityError异常

  SomeLargeModel.objects.all()

• 无法通过外键字段查找，因为还有其他（如default）数据库

  list(user.somelargemodel_set.all())