Python2连接Mysql数据库并发送带附件的邮件

本文涉及的产品
云数据库 RDS MySQL,集群系列 2核4GB
推荐场景:
搭建个人博客
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
云数据库 RDS PostgreSQL,集群系列 2核4GB
简介: 使用python连接mysql数据库读取数据,并发送带附件邮件

场景说明:公司运营小姐姐经常让我给她拉数据,为了避免重复工作,就搞了这个脚本。所以就有了这篇文章。

1、环境说明

1.1、开发环境

环境 版本 备注
系统 Windows 11
Python 2.7.5
IDE Pycharm 2022

1.2、运营环境

环境 版本 备注
系统 Linux Centos 7.5
Python 2.7.5

1.3、Python安装与配置

省略。请自行百度。

1.4、组件安装

首先用PyCharm随便创建一个项目,然后将创建一个python文件,然后将下面内容复制进去即可。

#!/usr/bin/env python

# coding=utf-8

importdatetime

importos

importsmtplib

fromemail.headerimportHeader

fromemail.mime.multipartimportMIMEMultipart

fromemail.mime.textimportMIMEText

fromemail.utilsimportparseaddr, formataddr

importMySQLdb

importxlwt

defcreateExcel():

   workbook=xlwt.Workbook(encoding='utf-8')

   returnworkbook

defcreateSheet(workbook, sheetname, fields, results):

   sheet=workbook.add_sheet(sheetname, cell_overwrite_ok=True)

   forifsinrange(0, len(fields)):

       sheet.write(0, ifs, fields[ifs][0])

   ics=1

   jcs=0

   foricsinrange(1, len(results) +1):

       forjcsinrange(0, len(fields)):

           sheet.write(ics, jcs, results[ics-1][jcs])

defgetDataFromDB(sql, cursor):

   cursor.execute(sql)

   results=cursor.fetchall()

   fields=cursor.description

   returnfields, results

def_format_addr(s):

   name, addr=parseaddr(s)

   returnformataddr(( \

       Header(name, 'utf-8').encode(), \

       addr.encode('utf-8') ifisinstance(addr, unicode) elseaddr))

defsendEmail(fileName, fileNameWithoutPath, timeflag):

   # 输入Email地址和口令:

   from_addr='zhgl.info@aliyun.com'

   password='zhgl123456'

   # 输入SMTP服务器地址:

   smtp_server='smtp.aliyun.com'

   smtp_port=465

   # 输入收件人地址:

   to_addr_list= ['anyofus4135@qq.com']

   content="积分兑换数明细报表"

   # 生成邮件体

   msg=MIMEMultipart('utf-8')

   msg['From'] =_format_addr(from_addr)

   to_addr= []

   foraddrinto_addr_list:

       to_addr.append(_format_addr(addr))

   msg['To'] =','.join(to_addr)

   msg['Subject'] =Header(u'用户积分兑换明细'+timeflag, 'utf-8').encode()

   body=MIMEText(content,'html','utf-8')

   msg.attach(body)

   att=MIMEText(open(fileName, 'rb').read(), 'base64', 'utf-8')

   att["Content-Type"] ='application/octet-stream'

   att["Content-Disposition"] ='attachment;filename="%s"'%Header(fileNameWithoutPath, 'utf-8').encode()

   msg.attach(att)

   # 连接邮件服务器发送邮件

   server=smtplib.SMTP_SSL(smtp_server, smtp_port)

   # server.set_debuglevel(1)

   server.login(from_addr, password)

   server.sendmail(from_addr, to_addr, msg.as_string())

   server.quit()

defmain():

   lastDate=datetime.date.today() -datetime.timedelta(days=1)

   timeflagToday=datetime.date.today().strftime('%Y-%m-%d')

   # 日志格式 yyyy-MM-dd

   timeflag=lastDate.strftime('%Y-%m-%d')

   timeflag_02=lastDate.strftime('%Y%m%d')

   conn=MySQLdb.connect(host='192.168.1.88', user='root', passwd='123456`', db='jack', port=3306,

                          charset='utf8')

   cursor=conn.cursor()

   sql_charge="SELECT pro_name 产品名称,CONVERT (AES_DECRYPT(UNHEX(user_mobile),'zhgl-iflytek') USING utf8) 用户手机号,receiver_name 收货人, receiver_address 收货地址,remark 备注,date_format(create_time, '%Y-%m-%d %H:%i:%S') 创建时间 FROM mall_order,mall_product WHERE mall_order.pro_id = mall_product.id"

   workbook=createExcel()

   fields, results=getDataFromDB(sql_charge, cursor)

   createSheet(workbook, "积分兑换明细", fields, results)

   cursor.close()

   conn.close()

   fileNameWithoutPath="积分兑换明细%s.xls"% (timeflagToday)

   fileName="d:/data/script/%s"% (fileNameWithoutPath)

   workbook.save(fileName)

   sendEmail(fileName, fileNameWithoutPath, timeflagToday)

   os.remove(fileName)

main()

1.4.1、开发环境组件安装

前提首先尝试用Pycharm安装对应的组件,会自动下载相关安装工具包pip。然后再结合下面手动进行安装。

  • 安装MySQLdb组件

MySQLdb组件是用来操作数据库的,我们使用PyCharm创建项目时创建了虚拟环境,将下载好的MySQL-Python文件复制到项目目录虚拟环境>venv>Scripts下面,地址https://www.lfd.uci.edu/~gohlke/pythonlibs/#mysql-python,找到对应版本的whl文件,如下图

网络异常,图片无法展示
|

执行命令进行安装

pip install MySQL_python‑1.2.5‑cp27‑none‑win_amd64.whl

  • 安装xlwt组件

xlwt组件作用是操作excel文件的,下载地址https://pypi.org/project/xlwt/#files,我这里下载的1.3.0版本

网络异常,图片无法展示
|

执行命令安装xlwt

pip install xlwt-1.3.0-py2.py3-none-any.whl

以上安装完成后,项目就不报错了,然后请自行替换里面的邮箱、数据库、sql等配置。

1.4.2、实际运行环境组件安装

我们运行的服务器python版本也是2.7.5,同样需要安装MySQLdb、xlwt。首先pip工具没有,我们要先安装pip。

yum install python-pip

安装MySQLdb组件

yum install MySQL-python

安装xlwt组件

pip install xlwt

2、部署及验证

2.1、部署

直接将调整好的脚本文件上传到服务器对应的目录下我这里放到了【/data/script】下面,然后增加执行权限

chmod+x score_charge_reord.py

网络异常,图片无法展示
|

2.2、验证

手动执行脚本

python score_charge_reord.py

查看邮件发送情况,是否收到邮件。

2.3、创建系统定时任务

在crond任务调度中增加我们的任务,每天早上9点执行发送脚本。编辑任务调度

crontab -e

将下面的内容粘贴到文件系统调度配置中

#每天早上九点发送用户积分兑换明细

0 9 * * *  python /data/script/score_charge_reord.py >> /data/script/score_charge_reord.log

重载系统调度服务

service crond reload

搞完后,以后让运营小姐姐每天9点自己查邮件即可,不会再来找我了。是不是挺爽的。

相关实践学习
如何在云端创建MySQL数据库
开始实验后,系统会自动创建一台自建MySQL的 源数据库 ECS 实例和一台 目标数据库 RDS。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助     相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
目录
相关文章
|
10天前
|
SQL 开发框架 .NET
ASP.NET连接SQL数据库:详细步骤与最佳实践指南ali01n.xinmi1009fan.com
随着Web开发技术的不断进步,ASP.NET已成为一种非常流行的Web应用程序开发框架。在ASP.NET项目中,我们经常需要与数据库进行交互,特别是SQL数据库。本文将详细介绍如何在ASP.NET项目中连接SQL数据库,并提供最佳实践指南以确保开发过程的稳定性和效率。一、准备工作在开始之前,请确保您
52 3
|
17天前
|
Java 关系型数据库 MySQL
如何用java的虚拟线程连接数据库
本文介绍了如何使用Java虚拟线程连接数据库,包括设置JDK版本、创建虚拟线程的方法和使用虚拟线程连接MySQL数据库的示例代码。
27 6
如何用java的虚拟线程连接数据库
|
11天前
|
SQL Java 数据库连接
如何使用`DriverManager.getConnection()`连接数据库,并利用`PreparedStatement`执行参数化查询,有效防止SQL注入。
【10月更文挑战第6天】在代码与逻辑交织的世界中,我从一名数据库新手出发,通过不断探索与实践,最终成为熟练掌握JDBC的开发者。这段旅程充满挑战与惊喜,从建立数据库连接到执行SQL语句,再到理解事务管理和批处理等高级功能,每一步都让我对JDBC有了更深的认识。示例代码展示了如何使用`DriverManager.getConnection()`连接数据库,并利用`PreparedStatement`执行参数化查询,有效防止SQL注入。
47 5
|
8天前
|
IDE 网络安全 开发工具
IDE之pycharm:专业版本连接远程服务器代码,并配置远程python环境解释器(亲测OK)。
本文介绍了如何在PyCharm专业版中连接远程服务器并配置远程Python环境解释器,以便在服务器上运行代码。
58 0
IDE之pycharm:专业版本连接远程服务器代码,并配置远程python环境解释器(亲测OK)。
|
9天前
|
关系型数据库 MySQL 数据库
Mysql学习笔记(四):Python与Mysql交互--实现增删改查
如何使用Python与MySQL数据库进行交互,实现增删改查等基本操作的教程。
20 1
|
9天前
|
Java 关系型数据库 MySQL
springboot学习五:springboot整合Mybatis 连接 mysql数据库
这篇文章是关于如何使用Spring Boot整合MyBatis来连接MySQL数据库,并进行基本的增删改查操作的教程。
14 0
springboot学习五:springboot整合Mybatis 连接 mysql数据库
|
13天前
|
SQL 存储 数据可视化
SQL 数据库大揭秘:连接数字世界的魔法桥梁
在数字化时代,数据如繁星般璀璨,而 SQL 数据库则像强大的引力场,有序汇聚、整理和分析这些数据。SQL 数据库是一个巨大的数字宝库,装满各行各业的“宝藏”。本文将带你探索 SQL 数据库在电商、金融、医疗和教育等领域的应用。例如,在电商中,它能精准推荐商品;在金融中,它是安全卫士,防范欺诈;在医疗中,它是健康管家,管理病历;在教育中,则是智慧导师,个性化教学。此外,还将介绍如何利用板栗看板等工具实现数据可视化,提升决策效率。
|
14天前
|
SQL 开发框架 .NET
ASP连接SQL数据库:从基础到实践
随着互联网技术的快速发展,数据库与应用程序之间的连接成为了软件开发中的一项关键技术。ASP(ActiveServerPages)是一种在服务器端执行的脚本环境,它能够生成动态的网页内容。而SQL数据库则是一种关系型数据库管理系统,广泛应用于各类网站和应用程序的数据存储和管理。本文将详细介绍如何使用A
30 3
|
16天前
|
数据库连接 网络安全 数据库
数据库网站连接错误怎么办?
数据库网站连接错误怎么办?
|
16天前
|
应用服务中间件 数据库连接 网络安全
网站连接数据库配置错误
网站连接数据库配置错误