内容摘要：Python/Django 支持分布式多租户数据库，如 Postgres+Citus。通过将租户上下文添加到您的查询来实现轻松横向扩展，使数据库(例如 Citus)能够有效地将查询路由到正确的数据库节

Python/Django 支持分布式多租户数据库，布式如 Postgres+Citus。多租

通过将租户上下文添加到您的户数查询来实现轻松横向扩展，使数据库(例如 Citus)能够有效地将查询路由到正确的据库数据库节点。

构建多租户数据库的项目架构包括：为每个租户创建一个数据库、为每个租户创建一个 schema 和让所有租户共享同一个表。实战这个库基于第三种设计，布式即让所有租户共享同一个表，多租它假设所有租户相关的户数模型/表都有一个 tenant_id 列来表示租户。

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

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

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

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

项目源码

https://github.com/citusdata/django-multitenant

安装

复制pip install --no-cache-dir django_multitenant1.

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

Python

Django

3.X

2.2

3.X

3.2

3.X

4.0

用法

为了使用这个库，项目您可以使用 Mixins 或让您的实战模型从我们的自定义模型类继承。网站模板

模型变化在要使用库的布式任何文件中导入它： 复制from django_multitenant.fields import *from django_multitenant.models import *1.2. 所有模型都应继承 TenantModel 类。Ex: class Product(TenantModel):定义一个名为 tenant_id 的多租静态变量，并使用该变量指定租户列。户数Ex: tenant_id=store_idTenantModel 子类的所有外键都应使用 TenantForeignKey 代替 models.ForeignKey实现上述 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)1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17. 使用 mixins 更改模型在您要使用库的任何文件中，只需： 复制from django_multitenant.mixins import *1. 所有模型都应使用 TenantModelMixin 和 django models.Model 或您的客户模型类 Ex: class Product(TenantModelMixin, models.Model):定义一个名为 tenant_id 的静态变量，并使用该变量指定租户列。Ex: tenant_id=store_idTenantModel 子类的所有外键都应使用 TenantForeignKey 代替 models.ForeignKey实现上述 2 个步骤的示例模型： 复制class ProductManager(TenantManagerMixin, models.Manager):

pass

class 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):

pass

class Purchase(TenantModelMixin, models.Model): store = models.ForeignKey(Store) tenant_id=store_id product_purchased = TenantForeignKey(Product) objects = PurchaseManager()1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.21.22.23. 在 db 层自动化复合外键：使用 TenantForeignKey 在租户相关模型之间创建外键将自动将 tenant_id 添加到引用查询(例如 product.purchases)和连接查询(例如 product__name)。如果要确保在 db 层创建复合外键(带有 tenant_id)，则应将 settings.py 中的数据库 ENGINE 更改为 django_multitenant.backends.postgresql。 复制default: { ENGINE: django_multitenant.backends.postgresql,

......

......

......

}1.2.3.4.5.6. 在哪里设置租户?使用中间件编写身份验证逻辑，该中间件还为每个 session/request 设置/取消设置租户。源码下载这样，开发人员不必担心基于每个视图设置租户。只需在身份验证时设置它，库将确保其余部分(将 tenant_id 过滤器添加到查询中)。上面的示例实现如下： 复制from django_multitenant.utils

import set_current_tenant

class MultitenantMiddleware: def __init__(self, get_response): self.get_response =

get_response

def __call__(self, request): if request.user and not request.user.is_anonymous: set_current_tenant(request.user.employee.company) return self.get_response(request)1.2.3.4.5.6.7.8.9.10.

在您的设置中，您需要更新 MIDDLEWARE 设置以包含您创建的设置。

复制MIDDLEWARE = [

# ...

# existing items

# ...

appname.middleware.MultitenantMiddleware]1.2.3.4.5.6. 在您希望基于租户范围的所有视图中使用 set_current_tenant(t) api 设置租户。这将自动(不指定显式过滤器)将所有 django API 调用范围限定为单个租户。如果未设置 current_tenant，则使用没有租户范围的 默认/原生 API。

支持的 API

Model.objects.* 下的大部分 API。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)

#Update

Purchase.objects.filter(id=1).update(id=1)

#Save

p=Product(8,1,Awesome Shoe,These shoes are awesome)p.save()

#Simple aggregates

Product.objects.count()Product.objects.filter(store__name=The Awesome Store).count()

#Subqueries

Product.objects.filter(name=Awesome Shoe);Purchase.objects.filter(product__in=p);1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.21.22.23.24.

源码库