如何在Django中同时向两个数据库插入数据？（含Change与Ip模型）

针对你的场景（Change模型存储Ip模型的变更日志，需要同时操作两个数据库），我会分步骤讲解具体实现方法，同时避开跨库关联的常见坑：

1. 首先配置多数据库连接 #

在你的settings.py中定义两个数据库，一个用于存储主业务数据（比如default），一个专门存储变更日志（比如log_db）：

DATABASES = {
    'default': {
        'ENGINE': 'django.db.backends.mysql',  # 可根据你的数据库类型调整（如postgresql）
        'NAME': 'main_business_db',
        'USER': 'your_db_user',
        'PASSWORD': 'your_db_password',
        'HOST': 'localhost',
        'PORT': '3306',
    },
    'log_db': {
        'ENGINE': 'django.db.backends.mysql',
        'NAME': 'change_log_db',
        'USER': 'your_db_user',
        'PASSWORD': 'your_db_password',
        'HOST': 'localhost',
        'PORT': '3306',
    }
}

2. 配置数据库路由（自动分配模型到对应库） #

在你的应用目录下创建routers.py文件，用来指定Change模型的读写操作都走log_db，其他模型使用默认库：

class LogDatabaseRouter:
    def db_for_read(self, model, **hints):
        # 读取Change模型时使用日志库
        if model._meta.model_name == 'change':
            return 'log_db'
        return 'default'

    def db_for_write(self, model, **hints):
        # 写入Change模型时使用日志库
        if model._meta.model_name == 'change':
            return 'log_db'
        return 'default'

    def allow_relation(self, obj1, obj2, **hints):
        # 允许跨库模型之间的关联（因为Change需要关联Ip等主库模型）
        return True

    def allow_migrate(self, db, app_label, model_name=None, **hints):
        # 指定Change模型只在日志库中执行迁移
        if model_name == 'change':
            return db == 'log_db'
        # 其他模型只在主库中执行迁移
        return db == 'default'

然后在settings.py中注册这个路由：

DATABASE_ROUTERS = ['your_app_name.routers.LogDatabaseRouter']

3. 修复跨库外键的问题 #

⚠️ 重要提醒：Django不支持跨数据库的外键关联（底层数据库大多也不支持跨库外键约束），所以你原来的Change模型中用外键关联Ip、Cluster等主库模型的写法会报错。建议调整为存储关联对象的ID，然后通过属性手动获取关联数据：

修改models.py中的Change模型：

from django.db import models

class Change(models.Model):
    author_id = models.IntegerField(null=False)  # 存储操作人ID
    ip_id = models.IntegerField(null=False)      # 存储关联Ip的ID
    old_cluster_id = models.IntegerField(null=False)
    old_status_id = models.IntegerField(null=False)
    new_cluster_id = models.IntegerField(null=False)
    new_status_id = models.IntegerField(null=False)
    change_time = models.DateTimeField(auto_now_add=True)  # 新增变更时间字段

    # 手动添加属性，从主库获取关联对象
    @property
    def author(self):
        from django.contrib.auth.models import User
        return User.objects.get(id=self.author_id)
    
    @property
    def ip(self):
        from .models import Ip
        return Ip.objects.get(id=self.ip_id)
    
    @property
    def old_cluster(self):
        from .models import Cluster
        return Cluster.objects.get(id=self.old_cluster_id)
    
    # 同理可添加old_status、new_cluster、new_status等属性

4. 实现同时插入的业务逻辑 #

现在你可以在业务代码中同时操作两个数据库了，比如当更新Ip模型时，同步记录变更日志：

from django.db import transaction
from .models import Ip, Change

def update_ip_with_log(ip_id, new_cluster_id, new_status_id, current_user):
    try:
        # 1. 从主库获取要更新的Ip实例
        ip_instance = Ip.objects.get(id=ip_id)
        old_cluster_id = ip_instance.cluster_id
        old_status_id = ip_instance.status_id

        # 2. 开启独立事务分别操作两个库
        with transaction.atomic(using='default'):
            # 更新Ip到主库
            ip_instance.cluster_id = new_cluster_id
            ip_instance.status_id = new_status_id
            ip_instance.save()
        
        with transaction.atomic(using='log_db'):
            # 写入变更日志到日志库
            Change.objects.create(
                author_id=current_user.id,
                ip_id=ip_instance.id,
                old_cluster_id=old_cluster_id,
                old_status_id=old_status_id,
                new_cluster_id=new_cluster_id,
                new_status_id=new_status_id
            )
        return True
    except Exception as e:
        # 这里可以根据业务需求添加异常处理，比如日志写入失败时的补偿逻辑
        print(f"操作失败: {str(e)}")
        return False

关于跨库事务一致性的补充 #

如果需要严格保证“Ip更新成功”和“日志写入成功”要么同时完成要么同时失败，Django默认事务无法直接实现（单个atomic只能绑定一个数据库）。你可以：

• 使用支持XA事务的数据库（如MySQL InnoDB开启XA），配合Django 4.2+支持的跨库原子事务：transaction.atomic(using=['default', 'log_db'])
• 或者采用最终一致性方案：用消息队列（如Celery）异步写入日志，若写入失败则自动重试，确保日志最终会被记录

内容的提问来源于stack exchange，提问作者Eduardo Correia