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主從復制。確保在配置過程中仔細檢查每個步驟，以避免數據不一致或其他問題。