软件开发文档清单,seo排名优化推荐,中企动力 网站建设 收费,pluto wordpress文章目录一、概述二、Python 连接数据源1#xff09;Python MySQL 基础操作1、部署MySQL2、MySQL Connector 库【1】安装 mysql-connector-python 库【2】连接 MySQL【3】增加数据【4】查询数据【5】更新数据【6】删除数据2、PyMySQL 库【1】安装 PyMySQL 库【2】连接 MySQL【…
文章目录一、概述二、Python 连接数据源1Python MySQL 基础操作1、部署MySQL2、MySQL Connector 库【1】安装 mysql-connector-python 库【2】连接 MySQL【3】增加数据【4】查询数据【5】更新数据【6】删除数据2、PyMySQL 库【1】安装 PyMySQL 库【2】连接 MySQL【3】增加数据【4】查询数据【5】更新数据【6】更新数据2Python Redis 基础操作1、部署 Redis2、Python Redis 基本操作【1】安装 Redis 客户端库【2】连接 Redis【3】设置键值对【4】获取键值对【5】删除键【6】判断键是否存在【7】设置过期时间【8】自增和自减三、邮件功能1开通邮箱服务功能1、邮件协议介绍2、QQ邮箱开启邮件服务设置3、163邮箱开启邮件服务设置2Python 邮件示例讲解一、概述
连接数据源和邮件发送和邮件接收也是在项目中很常见的功能数据量小的话可以存在MySQL、Redis、PostgreSQL 等等数据量大的话就可以考虑大型分布式高可用存储数据库系统例如Hadoop、StarRocks、ClickHouse等等。邮件发送一般用于通知像告警通知下单通知支付通知等等。 二、Python 连接数据源
1Python MySQL 基础操作
Python是一种流行的编程语言而MySQL是一种常用的关系型数据库管理系统。Python中有许多不同的MySQL库可供使用其中一些最常用的库包括
MySQL Connector——这是MySQL官方提供的Python库可以在Python 2.7和Python 3.x中使用。它提供了与MySQL数据库的连接和交互的API并支持多种操作系统。PyMySQL ——这是一个纯Python实现的MySQL客户端库可以在Python 2.7和Python 3.x中使用。它提供了一种简单而直接的方法来连接到MySQL服务器并执行查询和其他操作。
1、部署MySQL
MySQL的介绍和部署可以参考我以下几篇文章
面试宝典之——MysqlMySQL高可用实战 MHA【云原生】MySQL on k8s 环境部署
2、MySQL Connector 库
Python 通过 MySQL Connector 模块提供了访问 MySQL 数据库的能力可以通过该模块使用一系列的函数来进行数据库操作。
下面是一些常用的 Python MySQL 函数 connect()用于连接 MySQL 数据库返回一个连接对象。 cursor()用于创建一个游标对象该对象用于执行查询语句和读取数据。 execute()用于执行 SQL 语句返回受影响的行数。 fetchone()用于获取结果集中的下一行数据。 fetchall()用于获取结果集中的所有数据。 commit()用于提交事务。 rollback()用于回滚事务。 close()用于关闭连接。
以下是使用MySQL Connector进行连接和增删改查的演示示例。
【1】安装 mysql-connector-python 库
首先需要安装mysql-connector-python库
pip install mysql-connector-python【2】连接 MySQL
要进行数据库操作需要先连接MySQL数据库。连接MySQL数据库的代码如下
import mysql.connector# 连接到MySQL服务器
conn mysql.connector.connect(
userusername,
passwordpassword,
hosthostname,
databasedatabase_name
)mycursor conn.cursor()# 关闭连接
mycursor.close()
conn.close()在连接数据库时需要替换host、user、password和database为相应的值。
【3】增加数据
可以使用 execute() 函数执行 INSERT INTO 语句将数据插入到数据库中。以下是一个示例
import mysql.connector# 连接到MySQL服务器
conn mysql.connector.connect(
userusername,
passwordpassword,
hosthostname,
databasedatabase_name
)mycursor conn.cursor()sql INSERT INTO customers (name, address) VALUES (%s, %s)
val (John, Highway 21)
mycursor.execute(sql, val)conn.commit()print(mycursor.rowcount, record inserted.)# 关闭连接
mycursor.close()
conn.close()在这个例子中将一条记录插入到名为customers的表中。通过将数据作为元组传递给execute()方法将值插入到占位符中。最后需要使用commit()方法提交更改。
【4】查询数据
可以使用 execute() 函数执行 SELECT 语句查询数据库中的数据。以下是一个示例
import mysql.connector# 连接到MySQL服务器
conn mysql.connector.connect(
userusername,
passwordpassword,
hosthostname,
databasedatabase_name
)mycursor conn.cursor()mycursor.execute(SELECT * FROM customers)myresult mycursor.fetchall()for x in myresult:print(x)# 关闭连接
mycursor.close()
conn.close()在这个例子中从名为customers的表中选择所有记录并使用fetchall()方法将结果存储在变量myresult中。最后使用循环打印每个记录。
【5】更新数据
可以使用 execute() 函数执行 UPDATE 语句更新数据库中的数据。以下是一个示例
import mysql.connector# 连接到MySQL服务器
mydb mysql.connector.connect(
userusername,
passwordpassword,
hosthostname,
databasedatabase_name
)mycursor mydb.cursor()sql UPDATE customers SET address Canyon 123 WHERE address Highway 21mycursor.execute(sql)mydb.commit()print(mycursor.rowcount, record(s) affected)# 关闭连接
cursor.close()
conn.close()在这个例子中将名为customers的表中地址为Highway 21的记录的地址更新为Canyon 123。
【6】删除数据
可以使用 execute() 函数执行 DELETE 语句删除数据库中的数据。以下是一个示例
import mysql.connector# 连接到MySQL服务器
mydb mysql.connector.connect(
userusername,
passwordpassword,
hosthostname,
databasedatabase_name
)mycursor mydb.cursor()sql DELETE FROM customers WHERE address Canyon 123mycursor.execute(sql)mydb.commit()print(mycursor.rowcount, record(s) deleted)# 关闭连接
cursor.close()
conn.close()2、PyMySQL 库
Python PyMySQL 是一个纯 Python 实现的 MySQL 客户端库使用 PyMySQL 可以连接 MySQL 数据库并执行数据库操作。下面介绍一些 PyMySQL 常用的函数 connect()用于连接 MySQL 数据库返回一个连接对象。 cursor()用于创建一个游标对象该对象用于执行查询语句和读取数据。 execute()用于执行 SQL 语句返回受影响的行数。 executemany()用于执行多个 SQL 语句返回受影响的行数。 fetchone()用于获取结果集中的下一行数据。 fetchall()用于获取结果集中的所有数据。 fetchmany()用于获取结果集中指定数量的数据。 commit()用于提交事务。 rollback()用于回滚事务。 close()用于关闭连接。
【1】安装 PyMySQL 库
首先需要安装PyMySQL库
pip install PyMySQL【2】连接 MySQL
要进行数据库操作需要先连接MySQL数据库。连接MySQL数据库的代码如下
接下来连接到MySQL服务器并执行查询
import pymysql# 连接到MySQL服务器
conn pymysql.connect(hosthostname,portport,userusername,passwordpassword,dbdatabase_name,charsetutf8
)# 创建游标对象
mycursor conn.cursor()在上面的代码中需要将hostname、port、username、password和database_name替换为实际的数据库连接信息。
【3】增加数据
可以使用 execute() 函数执行 INSERT INTO 语句将数据插入到数据库中。以下是一个示例
import pymysql# 连接数据库
conn pymysql.connect(hostlocalhost,userusername,passwordpassword,databasemydatabase
)# 创建游标对象
mycursor conn.cursor()# 执行插入语句
sql INSERT INTO customers (name, address) VALUES (%s, %s)
val (John, Highway 21)
mycursor.execute(sql, val)# 提交事务
conn.commit()# 打印插入数据的 ID
print(mycursor.lastrowid)# 关闭连接
cursor.close()
conn.close()【4】查询数据
可以使用 execute() 函数执行 SELECT 语句查询数据库中的数据。以下是一个示例
import pymysql# 连接数据库
conn pymysql.connect(hostlocalhost,userusername,passwordpassword,databasemydatabase
)# 创建游标对象
mycursor conn.cursor()# 执行查询语句
sql SELECT * FROM customers
mycursor.execute(sql)# 获取结果集中的所有数据
myresult mycursor.fetchall()# 打印数据
for x in myresult:print(x)# 关闭连接
cursor.close()
conn.close()【5】更新数据
可以使用 execute() 函数执行 UPDATE 语句更新数据库中的数据。以下是一个示例
import pymysql# 连接数据库
conn pymysql.connect(hostlocalhost,userusername,passwordpassword,databasemydatabase
)# 创建游标对象
mycursor conn.cursor()# 执行更新语句
sql UPDATE customers SET address Canyon 123 WHERE address Highway 21
mycursor.execute(sql)# 提交事务
conn.commit()# 打印受影响的行数
print(mycursor.rowcount)# 关闭连接
cursor.close()
conn.close()【6】更新数据
可以使用 execute() 函数执行 DELETE 语句删除数据库中的数据。以下是一个示例
import pymysql# 连接数据库
conn pymysql.connect(hostlocalhost,userusername,passwordpassword,databasemydatabase
)# 创建游标对象
mycursor conn.cursor()# 执行删除语句
sql DELETE FROM customers WHERE address Canyon 123
mycursor.execute(sql)# 提交事务
conn.commit()# 打印受影响的行数
print(mycursor.rowcount)# 关闭连接
cursor.close()
conn.close()上述代码演示了如何连接到 MySQL 数据库、执行插入、更新、删除和查询操作以及关闭连接。在实际应用中还可以使用其他函数来执行复杂的操作如连接池、事务管理等。
2Python Redis 基础操作
Redis 是一种基于内存的数据结构存储系统它可以用作数据库、缓存和消息代理。Python 是一种流行的编程语言提供了一个 Redis 客户端库可以轻松地与 Redis 交互。下面是一些 Python Redis 基本操作的示例。
1、部署 Redis
Redis 的介绍和部署可以参考我以下几篇文章
面试宝典之——RedisRedis原理介绍与环境部署主从模式、哨兵模式、集群模式【云原生】Redis on k8s 编排部署讲解与实战操作
2、Python Redis 基本操作
【1】安装 Redis 客户端库
要在 Python 中使用 Redis需要安装 Redis 客户端库。可以使用 pip 工具安装
pip install redis【2】连接 Redis
在 Python 中连接 Redis需要使用 Redis 客户端库中的 Redis 类。可以使用以下代码连接到 Redis
import redisredis_client redis.Redis(hostlocalhost, port6379, db0)【3】设置键值对
可以使用 set 方法设置键值对
redis_client.set(key, value)也可以使用 mset 方法一次设置多个键值对
redis_client.mset({key1: value1, key2: value2})【4】获取键值对
可以使用 get 方法获取单个键的值
value redis_client.get(key)
print(value)也可以使用 mget 方法一次获取多个键的值
values redis_client.mget([key1, key2])
print(values)【5】删除键
可以使用 delete 方法删除一个键
redis_client.delete(key)也可以使用 delete 方法删除多个键
redis_client.delete(key1, key2)【6】判断键是否存在
可以使用 exists 方法判断一个键是否存在
exists redis_client.exists(key)
print(exists)【7】设置过期时间
可以使用 expire 方法设置一个键的过期时间以秒为单位
redis_client.expire(key, 60)也可以使用 expireat 方法设置一个键的过期时间以 Unix 时间戳为单位
import timeexpire_time int(time.time()) 60
redis_client.expireat(key, expire_time)【8】自增和自减
可以使用 incr 方法对一个键进行自增操作
redis_client.set(count, 0)
redis_client.incr(count)也可以使用 decr 方法对一个键进行自减操作
redis_client.set(count, 10)
redis_client.decr(count)以上是一些 Python Redis 的基本操作示例可以根据具体需要进行适当修改和调整。
三、邮件功能
Python 中可以使用标准库中的 smtplib 和 email 模块来发送和接收电子邮件。
1开通邮箱服务功能
1、邮件协议介绍
SMTP、POP3和IMAP都是电子邮件协议用于在计算机之间传递和接收电子邮件。 SMTPSimple Mail Transfer Protocol是用于发送电子邮件的协议。它定义了电子邮件如何通过互联网发送包括如何连接到邮件服务器、如何验证身份、如何传输邮件、如何处理错误等。 POP3Post Office Protocol version 3是用于接收电子邮件的协议。它定义了电子邮件如何从邮件服务器下载到本地计算机上的电子邮件客户端。POP3协议允许用户下载所有的邮件但是在本地计算机上只保留一份副本。 IMAPInternet Message Access Protocol也是用于接收电子邮件的协议。它定义了电子邮件如何从邮件服务器下载到本地计算机上的电子邮件客户端。IMAP协议允许用户对邮件进行管理和组织例如在本地计算机上创建文件夹来存储邮件而不是在邮件服务器上。这使得IMAP更适合那些需要在多个设备上使用电子邮件的用户。 总之SMTP、POP3和IMAP是三种不同的协议每个协议都有其独特的作用使得电子邮件的发送和接收变得更加便捷和高效。简单地说SMTP管发POP3/IMAP管收。 POPPost Office Protocol和 IMAPInternet Message Access Protocol都是电子邮件客户端和邮件服务器之间的协议但是它们在处理电子邮件的方式上有一些重要的区别 工作方式POP将邮件从邮件服务器下载到本地计算机上的邮件客户端然后将邮件从邮件服务器中删除这意味着用户只能在本地计算机上访问邮件的一份副本而IMAP将邮件保留在邮件服务器上只有在用户请求访问邮件时才会下载邮件到本地计算机上的邮件客户端。 多设备支持由于POP只下载邮件的一份副本到本地计算机上因此如果用户使用多个设备如电脑、平板电脑、智能手机等来访问邮件则每个设备上的邮件客户端都会显示不同的邮件状态。而IMAP协议允许用户在多个设备上访问邮件因为邮件始终保留在邮件服务器上。 邮件管理IMAP允许用户在邮件服务器上对邮件进行管理例如创建、删除和重命名文件夹标记邮件已读或未读等。这使得用户可以轻松地在多个设备之间同步邮件状态。而POP协议只是简单地下载邮件并删除它们不能像IMAP那样管理邮件。 带宽由于IMAP只在用户需要访问邮件时才下载邮件因此它可以节省带宽。而POP在每次下载邮件时都会占用带宽因为它要下载所有邮件的一份副本。 总之IMAP是更先进的邮件协议可以提供更多的功能和灵活性特别是对于那些需要在多个设备上访问邮件的用户。而POP适合那些只使用单个设备访问邮件的用户。 2、QQ邮箱开启邮件服务设置 3、163邮箱开启邮件服务设置 最后整理一下邮箱服务器
2Python 邮件示例讲解
以下是一个简单的 Python 脚本演示了如何使用这两个模块来发送电子邮件。
发送邮件实例
import smtplib
from email.mime.text import MIMEText
from email.header import Header# 设置邮件参数
smtp_server smtp.example.com # 邮件服务器
from_addr your_emailexample.com # 发件人邮箱
to_addr recipient_emailexample.com # 收件人邮箱
username your_emailexample.com # 发件人邮箱账号
password your_email_password # 发件人邮箱密码# 构建邮件内容
msg MIMEText(Hello, this is a test email sent by Python., plain, utf-8)
msg[From] Header(Sender Name, utf-8)
msg[To] Header(Recipient Name, utf-8)
msg[Subject] Header(Python Test Email, utf-8)# 发送邮件
try:server smtplib.SMTP(smtp_server, 25)server.login(username, password)server.sendmail(from_addr, to_addr, msg.as_string())server.quit()print(Email sent successfully!)
except smtplib.SMTPException:print(Error: 无法发送邮件)接收邮件示例
import poplib# 设置邮件参数
pop_server pop.example.com # 邮件服务器
username your_emailexample.com # 邮箱账号
password your_email_password # 邮箱密码# 连接到邮件服务器
server poplib.POP3(pop_server)
server.user(username)
server.pass_(password)# 获取邮件列表
resp, mails, octets server.list()
print(Total emails: {}.format(len(mails)))# 获取最新一封邮件
resp, lines, octets server.retr(len(mails))
msg_content b\n.join(lines).decode(utf-8)# 解析邮件内容
from email.parser import Parser
msg Parser().parsestr(msg_content)
print(Subject: {}.format(msg[Subject]))
print(From: {}.format(msg[From]))
print(To: {}.format(msg[To]))
print(Content:\n{}.format(msg.get_payload()))这里的示例代码仅仅是一个简单的示例可以根据具体的需要来修改和扩展。在使用示例时注意修改上面的连接信息哦。 Python 连接数据源与邮件功能的讲解就先到这里了有任何疑问欢迎给我留言哦欢迎点赞、转发并收藏哦也可关注我的公众号【大数据与云原生技术分享】进行深入交流技术~
