使用Python自动备份MySQL数据库并发送至指定邮箱

在IT行业中，数据库管理是至关重要的任务之一，特别是在企业级应用中，数据的安全与备份是保障业务连续性的重要环节。Python作为一种强大而灵活的编程语言，常被用于自动化任务，包括MySQL数据库的备份。本教程将详细介绍如何使用Python来备份MySQL数据库，并将备份文件通过电子邮件发送到指定的邮箱。

你需要确保已经安装以下Python库：

1. pymysql：用于连接和操作MySQL数据库。

2. schedule：用于定时任务，例如定期备份。

3. smtplib 和 email：用于发送电子邮件。

步骤一：配置数据库连接

在Python脚本中，创建一个包含数据库连接信息的字典，例如：

 db_config = {
    'host': 'localhost',
    'user': 'your_username',
    'password': 'your_password',
    'database': 'your_database_name'
}

步骤二：编写数据库备份函数

使用pymysql库创建一个函数来执行SQL命令，导出数据库为SQL文件：

import pymysql
import os

def backup_db(config):
    with pymysql.connect(**config) as conn:
        cursor = conn.cursor()
        # 创建SQL备份语句
        sql = f\"mysqldump --user={config['user']} --password={config['password']} {config['database']} > backup.sql\"
        # 在操作系统层面执行SQL语句
        os.system(sql)

注意：此命令将直接调用操作系统shell命令，需谨慎。

步骤三：设置邮件发送

使用smtplib和email库设置邮件服务器、发件人、收件人以及附件信息：

import smtplib
from email.mime.multipart import MIMEMultipart
from email.mime.text import MIMEText
from email.mime.application import MIMEApplication

# 创建邮件发送函数
 def send_email_with_backup(to_address):
    msg = MIMEMultipart()
    msg['From'] = 'your_email@example.com'
    msg['To'] = to_address
    msg['Subject'] = 'MySQL数据库备份'

    # 添加邮件内容
    msg.attach(MIMEText('请查收数据库备份文件。', 'plain'))

    # 添加附件
    with open('backup.sql', 'rb') as attachment:
        part = MIMEApplication(attachment.read(), Name='backup.sql')
        part['Content-Disposition'] = 'attachment; filename=\"backup.sql\"'
        msg.attach(part)

    # 设置SMTP服务器
    server = smtplib.SMTP('smtp.example.com', 587)
    server.starttls()
    server.login('your_email@example.com', 'your_password')
    server.sendmail(msg['From'], msg['To'], msg.as_string())
    server.quit()

步骤四：定时备份任务

使用schedule库定期执行备份和邮件发送操作：

import schedule
import time

schedule.every().day.at('01:00').do(backup_db, config=db_config)
schedule.every().day.at('01:30').do(send_email_with_backup, to_address='recipient@example.com')

while True:
    schedule.run_pending()
    time.sleep(60)