网站建设小组的五类成员,品牌建设实施纲要,做封面字体下载好的网站,公司网站注销流程Django分表方案
方案一#xff1a;轮询方式分表
当系统数据越来越多的时候#xff0c;查询变得缓慢#xff0c;即使加了索引#xff0c;由于表数据的增加#xff0c;索引的维护也会成为数据库性能的限制问题#xff0c;所以此时可以通过分表#xff0c;将数据通过某种…Django分表方案
方案一轮询方式分表
当系统数据越来越多的时候查询变得缓慢即使加了索引由于表数据的增加索引的维护也会成为数据库性能的限制问题所以此时可以通过分表将数据通过某种准则分别存储到不同的表中以实现缓解单表的压力。
分表的方法大部分都是通过主键id取数据库分表个数的余。最简单的方法就是定义多个Model对象然后通过一个map的映射当我们获取具体的Model的时候直接就通过id与表个数取余然后通过map的映射我们可以获取到具体的表model对象。
class User(models.Model): user_id models.IntegerField(primary_keyTrue)user_name models.CharField(max_length256)password models.CharField(max_length256)class User0(User):class Meta:db_table user_0
class User1(User):class Meta:db_table user_1
class User2(User):class Meta:db_table user_2
user_model_map {0: User0,1: User1,2: User2,
}
table_num 3# 获取表的model
def get_user_db_model(user_id):key user_id % table_numreturn user_model_map[key]但如果表数量躲到几百甚至上千这种方案就很不使用。
所以我们使用第二种方案首先我们需要思考为什么在我们使用User.objects.first()的时候Django可以找到具体的User表这是因为设置了Meta.db_table具体名称django可以找到具体的表进行数据的查询。
如果是多张表呢我们可以想到可以动态的创建多个表的具体名称这样的话在我们程序运行过程中只要我们传入一个id此时可以动态的获取到具体的表的名称就可以找到具体的表实现具体的分表作用。
要想实现动态数据变更就需要使用到反射Python原生支持反射的我们可以使用type完成新类的创建。实际上主要的功能就是获取表model的时候动态修改内部的Meta.db_table部分的信息即可。
SHARD_TABLE_NUM 3
class User(models.Model):classmethoddef get_student_db_model(cls, user_idNone):suffix user_id % SHARD_TABLE_NUMtable_name user_%s % suffix# construct a private field _user_model_dict to store the model,# it can help to accelerate the speed of get modelif table_name in cls._user_model_dict:return cls._user_model_dict[table_name]class Meta:db_table table_nameattrs {__module__: cls.__module__,Meta: Meta}# the first param is obejct name# second: class# the class field infouser_db_model type(str(User_%s) % suffix, (cls,), attrs)cls._user_model_dict[table_name] user_db_modelreturn user_db_model_user_model_dict {} # help to reuse the model objectid models.AutoField(primary_keyTrue)user_name models.CharField(max_length256)password models.CharField(max_length256)class Meta:abstract True上面的代码通过编写一个类方法先获取到表的名称具体的获取方法就是采用id取余的方法来实现的。在获取到表名之后通过class Meta对象最后通过attrs的属性装配最后由type实现新类的构建。
def __init__(cls, what, basesNone, dictNone): # known special case of type.__init__type(object) - the objects typetype(name, bases, dict) - a new type # 构建新的type即类对象# (copied from class doc)pass最后就可以实现具体的分表操作但是需要注意当我们插入的时候因为需要提前知道id这个时候最好采用一个辅助的Model类来协助id的生成便于我们后续具体分表的实施具体表的设计如下
# the sharding table of Django
class UserIndex(models.Model):id models.AutoField(primary_keyTrue)class Meta:db_table user_index_tab方案二动态迁移
通过某一张表的一个字段password_code进行动态的创建models类加入app的model应用中心去
#动态创建模型
def create_task_detail_model(password_code):if password_code:classname fTaskDetail_{password_code}class Meta:db_table classnamemodel_class type(classname, (models.Model,), {task: models.ForeignKey(Task, on_deletemodels.CASCADE, related_namedetails, verbose_name任务),user_id: models.IntegerField(verbose_name用户ID),created_time: models.DateTimeField(auto_now_addTrue, verbose_name创建时间),is_complet: models.BooleanField(defaultFalse, verbose_name是否完成),__str__: lambda self: f{self.task.password_code} - {self.user_id},Meta: Meta,__module__: __name__,})# Register the model with the apps registryapps.all_models[your_app_name][classname] model_classreturn model_classelse:classname fTaskDetailclass Meta:db_table classnamemodel_class type(classname, (models.Model,), {task: models.ForeignKey(Task, on_deletemodels.CASCADE, related_namedetails, verbose_name任务),user_id: models.IntegerField(verbose_name用户ID),created_time: models.DateTimeField(auto_now_addTrue, verbose_name创建时间),is_complet: models.BooleanField(defaultFalse, verbose_name是否完成),__str__: lambda self: f{self.task.password_code} - {self.user_id},Meta: Meta,__module__: __name__,})# Register the model with the apps registryapps.all_models[your_app_name][classname] model_classreturn model_class动态的使用模型类
model_class apps.get_model(your_app_name, class_name)开启服务就加入到apps中的model中就使用信号机制
在signalstask.py中配置自动装配逻辑前提是在对应的表存在的情况下装配的
receiver(startup_complete)
def create_dynamic_models(sender, **kwargs):Task apps.get_model(your_app_name, Task) # Replace with the actual name of your app# Iterate over existing tasks and create corresponding modelsfor task in Task.objects.all():create_task_detail_model(task.password_code)apps.py中配置
from django.apps import AppConfigclass TaskmanageConfig(AppConfig):default_auto_field django.db.models.BigAutoFieldname your_app_namedef ready(self):import your_app_name.signalstask # 导入信号文件以进行连接post_migrate.connect(self.on_startup_complete, senderself)def on_startup_complete(self, sender, **kwargs):from your_app_name.signalstask import startup_complete# 在这里发送服务启动完成的信号startup_complete.send(senderself)Django分库方案
分库的方案有两种
采取路由的方式设置具体的app_label按照app_label的不同分配到不同的库 采用自己编写方法在具体的Model中配置好相应的库从而实现分库
1、DB路由方式
DB路由方式设置一个DB路由的规则根据规则的不同对应的数据库的读写会映射到不同的库上面以User为例假设sharding项目的数据存储到sharding库中sharding_one项目的数据存储到sharding_one数据库中此时可以编写一个DbRouter如下
class DbRouter(object):def db_for_read(self, model, **hints):if model._meta.app_label sharding_one: # 判断app_label标签这个可以在model中设置return sharding_onereturn Nonedef db_for_write(self, model, **hints):if model._meta.app_label sharding_one:return sharding_onereturn None为什么不为sharding_one就返回None呢因为这里仅有两个项目一个对应着sharding库一个对应着sharding_one库而django程序有个默认库default返回None的话表示直接对应sharding库。 具体的Model中的设置
# sharding_one
class Meta:abstract Trueapp_label sharding_one这样最后只需要在不同的项目中执行数据读取或者写入操作库的切换就通过DB路由切换到了设置的库从而实现了分库的操作。
2、Config配置方式
采用Config配置方式是一种比较方便的形式即在Model中配置一个内部类Config而Config中的属性则对映射具体的写数据和读数据的库操作。
这种方式的话需要写一个获取DB节点的操作可以使用objects.using(‘db_name’)指定连接具体的数据库。
首先在model中添加具体的Config配置
class Config:db_for_read sharding_onedb_for_write sharding_one写一个获取db节点的方法
这个方法先从Config中获取到具体的数据库节点名称在指定自己使用当前的库
def get_db_obj(objects):db_name objects.model.Config.db_for_writereturn objects.using(db_name)最后写入和查询的代码分别如下
def search_user_service(user_id):# get_student_db_model()就是前面的分表方案中的设计获取到具体的指定表的model信息然后从中获取到objects# 然后通过这个表对象指定具体的库即可最后从库中查询出具体的数据obj get_db_obj(User.get_student_db_model(user_id).objects)user obj.first()return userdef insert_user_service(user_name, password):index UserIndex() # 这里是因为分表之后需要插入数据的话怎么提前获得到主键呢采用user_index表获取一个自增的主键或者按照自己设计的方式生成的主键index.save()user_id index.id# 这里与之前一样但是由于是插入所以对象构造成功之后需要取出内部的model进行数据的填充操作model get_db_obj(User.get_student_db_model(user_iduser_id).objects).model(user_id, user_name, password)try:model.save() # 最后数据保存即可except Exception as e:print [insert_user] exception error %s % e通过上面的方式我们可以实现具体的分库分表操作这种方式比较有效对于分库较多的操作比如写主库读从库的操作可以通过这个Config配置直接可以实现而获取db的时候需要多补写几个方法就是指定使用db库的方法这样看起来会更加的直观
小结 之前是看过学习java的分表操作由于java比较成熟各种三方工具包的引入可以很轻松的完成分表以及分库操作但对于Python而言Django的ORM是不支持分库分表的所以需要构造具体的分库分表逻辑分表的话可以采用动态构造类Model的方式来实现分库的话可以借助具体的DB路由的配置编写路由配置类来实现具体的库名称的获取从而实现分库操作同时我们还可以自己通过给Model添加config的属性从而利用objects.using(db_name)的方式来获取具体的库实现分库。
