Python实现定时备份mysql数据库并把备份数据库邮件发送

当我们的网站使用了MySQL数据库时，定时备份数据库是非常重要的。本文将介绍Python如何实现定时备份MySQL数据库并将备份数据库发送电子邮件的完整攻略。步骤如下：

1. 安装pymysql模块

我们使用Python的pymysql模块来连接数据库并执行备份操作，所以需要安装该模块。可以在命令行中执行以下命令安装：

pip install pymysql

2. 安装smtplib模块

我们使用Python的smtplib模块来发送邮件，所以需要安装该模块。可以在命令行中执行以下命令安装：

pip install secure-smtplib

3. 编写备份脚本

我们可以编写Python脚本来执行备份操作。示例代码如下：

import os
import time
import smtplib
import pymysql
import zipfile
from email.mime.text import MIMEText
from email.mime.multipart import MIMEMultipart
from email.mime.base import MIMEBase
from email import encoders

# MySQL数据库连接配置
DB_HOST = 'localhost'
DB_NAME = 'mydatabase'
DB_USER = 'myuser'
DB_PASS = 'mypassword'

# 备份文件保存路径
BACKUP_PATH = '/path/to/backup/directory/'

# 邮件配置
FROM_EMAIL = '[e-mail]'
TO_EMAIL = '[e-mail]'
EMAIL_PASS = 'emailpassword'  # 邮箱授权码


def send_email(subject, message, attachment):
    """
    发送邮件
    :param subject: 邮件主题
    :param message: 邮件内容
    :param attachment: 附件路径
    """
    # 创建一个多部分(MIMEMultipart)对象
    email = MIMEMultipart()
    email['From'] = FROM_EMAIL
    email['To'] = TO_EMAIL
    email['Subject'] = subject

    # 将邮件内容添加到对象中
    message = MIMEText(message)
    email.attach(message)

    # 如果有附件，则添加到对象中
    if attachment:
        with open(attachment, 'rb') as f:
            attachment_part = MIMEBase('application', 'octet-stream')
            attachment_part.set_payload(f.read())
            encoders.encode_base64(attachment_part)
            attachment_part.add_header(
                'Content-Disposition',
                f'attachment; filename="{os.path.basename(attachment)}"'
            )
            email.attach(attachment_part)

    # 创建SMTP对象并发送邮件
    with smtplib.SMTP_SSL('smtp.gmail.com', 465) as smtp:
        smtp.login(FROM_EMAIL, EMAIL_PASS)
        smtp.sendmail(FROM_EMAIL, TO_EMAIL, email.as_string())


def backup_database():
    """
    备份数据库
    """
    # 连接数据库
    db = pymysql.connect(
        host=DB_HOST,
        user=DB_USER,
        password=DB_PASS,
        database=DB_NAME,
        charset='utf8'
    )

    # 获取当前时间
    current_time = time.strftime('%Y-%m-%d_%H-%M-%S')

    # 备份文件名
    backup_file_name = f'{DB_NAME}_{current_time}.sql'

    # 备份文件完整路径
    backup_file_path = os.path.join(BACKUP_PATH, backup_file_name)

    # 执行备份命令
    os.system(f'mysqldump -u {DB_USER} -p{DB_PASS} {DB_NAME} > {backup_file_path}')

    # 关闭数据库连接
    db.close()

    # 压缩备份文件
    zip_file_name = f'{DB_NAME}_{current_time}.zip'
    zip_file_path = os.path.join(BACKUP_PATH, zip_file_name)
    with zipfile.ZipFile(zip_file_path, 'w') as zip_file:
        zip_file.write(backup_file_path, arcname=os.path.basename(backup_file_path))

    # 删除原始备份文件
    os.remove(backup_file_path)

    # 发送邮件
    subject = 'MySQL Backup'
    message = 'Please find attached the backup of the MySQL database.'
    send_email(subject, message, zip_file_path)

以上代码实现了备份MySQL数据库的功能。备份文件会压缩为zip格式并发送电子邮件。

4. 使用crontab定时执行备份脚本

对于Linux系统，我们可以使用crontab定时执行备份脚本。示例命令如下：

*/30 * * * * python /path/to/backup_script.py

上面的命令将会每30分钟执行一次备份脚本。

示例

示例1：备份单个数据库

假设我们有一个MySQL数据库名为“test”，我们可以修改脚本中的以下配置：

DB_NAME = 'test'

然后执行备份脚本：

python /path/to/backup_script.py

脚本将会连接“test”数据库并备份数据，然后压缩为zip格式并发送邮件。备份文件将保存在 BACKUP_PATH 目录中。

示例2：备份多个数据库

如果我们需要备份多个MySQL数据库，可以更改备份脚本的代码以备份多个数据库。例如：

def backup_database(db_name):
    """
    备份数据库
    """
    # 连接数据库
    db = pymysql.connect(
        host=DB_HOST,
        user=DB_USER,
        password=DB_PASS,
        database=db_name,
        charset='utf8'
    )

    # 获取当前时间
    current_time = time.strftime('%Y-%m-%d_%H-%M-%S')

    # 备份文件名
    backup_file_name = f'{db_name}_{current_time}.sql'

    # 备份文件完整路径
    backup_file_path = os.path.join(BACKUP_PATH, backup_file_name)

    # 执行备份命令
    os.system(f'mysqldump -u {DB_USER} -p{DB_PASS} {db_name} > {backup_file_path}')

    # 关闭数据库连接
    db.close()

    # 压缩备份文件
    zip_file_name = f'{db_name}_{current_time}.zip'
    zip_file_path = os.path.join(BACKUP_PATH, zip_file_name)
    with zipfile.ZipFile(zip_file_path, 'w') as zip_file:
        zip_file.write(backup_file_path, arcname=os.path.basename(backup_file_path))

    # 删除原始备份文件
    os.remove(backup_file_path)

    # 发送邮件
    subject = f'MySQL Backup - {db_name}'
    message = f'Please find attached the backup of the {db_name} MySQL database.'
    send_email(subject, message, zip_file_path)

# 备份多个数据库
db_names = ['test1', 'test2', 'test3']
for db_name in db_names:
    backup_database(db_name)

上述代码将连接“test1”、“test2”和“test3”三个数据库进行备份。您可以将这些数据库名称替换为您自己的数据库名称或使用其他用于指定数据库名称的方法。