Django-Multitenant，分布式多租户数据库项目实战(Python/Django+Postgres+Citus)

Python/Django

支持分布式多租户数据库，如

Postgres+Citus

。

通过将租户上下文添加到您的查询来实现轻松横向扩展，使数据库（例如

Citus

）能够有效地将查询路由到正确的数据库节点。

构建多租户数据库的架构包括：为每个租户创建一个数据库、为每个租户创建一个

schema

和让所有租户共享同一个表。这个库基于第三种设计，即让所有租户共享同一个表，它假设所有租户相关的

模型/表

都有一个

tenant_id

列来表示租户。

以下链接更多地讨论了何时以及如何为您的多租户数据库选择正确架构的权衡：

• https://www.citusdata.com/blog/2016/10/03/designing-your-saas-database-for-high-scalability/</small>

关于多租户的其他有用链接：

1. https://www.citusdata.com/blog/2017/03/09/multi-tenant-sharding-tutorial/</small>
2. https://www.citusdata.com/blog/2017/06/02/scaling-complex-sql-transactions/</small>

项目源码

https://github.com/citusdata/django-multitenant</small>

安装

pip install --no-cache-dir django_multitenant

支持的 Django 版本/前提条件。

用法

为了使用这个库，您可以使用

Mixins

或让您的模型从我们的自定义模型类继承。

模型变化

1. 在要使用库的任何文件中导入它：

   from django_multitenant.fields import *from django_multitenant.models import *

2. 所有模型都应继承

   TenantModel

   类。

   Ex: class Product(TenantModel):

3. 定义一个名为

   tenant_id

   的静态变量，并使用该变量指定租户列。

   Ex: tenant_id=\'store_id\'

4. TenantModel

   子类的所有外键都应使用

   TenantForeignKey

   代替

   models.ForeignKey

5. 实现上述

   2

   个步骤的示例模型：

   class Store(TenantModel):tenant_id = \'id\'name =  models.CharField(max_length=50)address = models.CharField(max_length=255)email = models.CharField(max_length=50)class Product(TenantModel):store = models.ForeignKey(Store)tenant_id=\'store_id\'name = models.CharField(max_length=255)description = models.TextField()class Meta(object):unique_together = ["id", "store"]class Purchase(TenantModel):store = models.ForeignKey(Store)tenant_id=\'store_id\'product_purchased = TenantForeignKey(Product)

使用 mixins 更改模型

1. 在您要使用库的任何文件中，只需：

   from django_multitenant.mixins import *

2. 所有模型都应使用

   TenantModelMixin

   和 django

   models.Model

   或您的客户模型类

   Ex: class Product(TenantModelMixin, models.Model):

3. 定义一个名为

   tenant_id

   的静态变量，并使用该变量指定租户列。

   Ex: tenant_id=\'store_id\'

4. TenantModel

   子类的所有外键都应使用

   TenantForeignKey

   代替

   models.ForeignKey

5. 实现上述 2 个步骤的示例模型：

   class ProductManager(TenantManagerMixin, models.Manager):passclass Product(TenantModelMixin, models.Model):store = models.ForeignKey(Store)tenant_id=\'store_id\'name = models.CharField(max_length=255)description = models.TextField()objects = ProductManager()class Meta(object):unique_together = ["id", "store"]class PurchaseManager(TenantManagerMixin, models.Manager):passclass Purchase(TenantModelMixin, models.Model):store = models.ForeignKey(Store)tenant_id=\'store_id\'product_purchased = TenantForeignKey(Product)objects = PurchaseManager()

在

db

层自动化复合外键：

1. 使用

   TenantForeignKey

   在租户相关模型之间创建外键将自动将

   tenant_id

   添加到引用查询（例如

   product.purchases

   ）和连接查询（例如

   product__name

   ）。如果要确保在

   db

   层创建复合外键（带有

   tenant_id

   ），则应将

   settings.py

   中的数据库

   ENGINE

   更改为

   django_multitenant.backends.postgresql

   。

   \'default\': {\'ENGINE\': \'django_multitenant.backends.postgresql\',..................}

在哪里设置租户？

1. 使用中间件编写身份验证逻辑，该中间件还为每个

   session/request

   设置/取消设置租户。 这样，开发人员不必担心基于每个视图设置租户。只需在身份验证时设置它，库将确保其余部分（将

   tenant_id

   过滤器添加到查询中）。上面的示例实现如下：

   from django_multitenant.utils import set_current_tenantclass MultitenantMiddleware:def __init__(self, get_response):self.get_response = get_responsedef __call__(self, request):if request.user and not request.user.is_anonymous:set_current_tenant(request.user.employee.company)return self.get_response(request)

   在您的设置中，您需要更新

   MIDDLEWARE

   设置以包含您创建的设置。

   MIDDLEWARE = [# ...# existing items# ...\'appname.middleware.MultitenantMiddleware\']

2. 在您希望基于租户范围的所有视图中使用

   set_current_tenant(t)

   api 设置租户。 这将自动（不指定显式过滤器）将所有

   django API

   调用范围限定为单个租户。如果未设置

   current_tenant

   ，则使用没有租户范围的

   默认/原生

   API。

支持的 API

1. Model.objects.*

   下的大部分

   API

   。

2. Model.save()

   为租户继承的模型注入

   tenant_id

   。

s=Store.objects.all()[0]set_current_tenant(s)#All the below API calls would add suitable tenant filters.#Simple get_queryset()Product.objects.get_queryset()#Simple joinPurchase.objects.filter(id=1).filter(store__name=\'The Awesome Store\').filter(product__description=\'All products are awesome\')#UpdatePurchase.objects.filter(id=1).update(id=1)#Savep=Product(8,1,\'Awesome Shoe\',\'These shoes are awesome\')p.save()#Simple aggregatesProduct.objects.count()Product.objects.filter(store__name=\'The Awesome Store\').count()#SubqueriesProduct.objects.filter(name=\'Awesome Shoe\');Purchase.objects.filter(product__in=p);

更多

• Django-Multitenant，分布式多租户数据库项目实战(Python/Django+Postgres+Citus)
• 分布式 PostgreSQL 集群(Citus)官方示例 – 时间序列数据