MySQL主从复制在Django中的维护

MySQL主从复制是一种常见的数据库架构模式，用于提高系统的可用性和读取性能。在Django中，你可以通过以下步骤来维护和操作MySQL主从复制：

1. 配置MySQL主从复制

首先，确保你的MySQL数据库已经配置为主从复制。以下是一个基本的配置示例：

主服务器配置（master）

-- 启用二进制日志
SET GLOBAL log_bin = ON;

-- 创建一个用于复制的用户
CREATE USER 'repl'@'%' IDENTIFIED BY 'password';
GRANT REPLICATION SLAVE ON *.* TO 'repl'@'%';
FLUSH PRIVILEGES;

从服务器配置（slave）

-- 停止复制
STOP SLAVE;

-- 配置从服务器连接到主服务器
CHANGE MASTER TO 
MASTER_HOST='master_ip', 
MASTER_USER='repl', 
MASTER_PASSWORD='password', 
MASTER_LOG_FILE='binlog_file_name', 
MASTER_LOG_POS=binlog_position;

-- 启动复制
START SLAVE;

2. 在Django中配置数据库连接

在你的Django项目的settings.py文件中，配置主从数据库连接。你可以使用django-db-connection-router库来管理多个数据库连接。

首先，安装django-db-connection-router：

pip install django-db-connection-router

然后，在settings.py中配置：

DATABASES = {
    'default': {
        'ENGINE': 'django.db.backends.mysql',
        'NAME': 'default_db',
        'USER': 'default_user',
        'PASSWORD': 'default_password',
        'HOST': 'localhost',
        'PORT': '3306',
    },
    'master': {
        'ENGINE': 'django.db.backends.mysql',
        'NAME': 'master_db',
        'USER': 'master_user',
        'PASSWORD': 'master_password',
        'HOST': 'master_ip',
        'PORT': '3306',
    },
    'slave': {
        'ENGINE': 'django.db.backends.mysql',
        'NAME': 'slave_db',
        'USER': 'slave_user',
        'PASSWORD': 'slave_password',
        'HOST': 'slave_ip',
        'PORT': '3306',
    },
}

# 使用django-db-connection-router
DATABASE_ROUTERS = ['path.to.your.DatabaseRouter']

创建一个DatabaseRouter类来管理数据库路由：

# path/to/your/DatabaseRouter.py
class DatabaseRouter:
    def db_for_read(self, model, **hints):
        return 'master' if hints.get('read_replica', False) else 'default'

    def db_for_write(self, model, **hints):
        return 'default'

    def allow_relation(self, obj1, obj2, **hints):
        return True

    def allow_migrate(self, db, app_label, model_name=None, **hints):
        return True

3. 使用Django查询主从数据库

在你的Django应用中，你可以根据需要选择使用主数据库或从数据库进行查询。例如：

from django.db import connections

def get_data():
    with connections['master'].cursor() as cursor:
        cursor.execute("SELECT * FROM myapp_mymodel")
        data = cursor.fetchall()
    return data

4. 监控和维护

定期检查主从复制的状态，确保数据同步正常。你可以使用以下命令检查复制状态：

SHOW SLAVE STATUS\G;

确保Slave_IO_Running和Slave_SQL_Running都是Yes，并且Seconds_Behind_Master在可接受的范围内。

总结

通过以上步骤，你可以在Django中配置和管理MySQL主从复制。确保在配置过程中仔细检查每个步骤，以避免数据不一致或其他问题。