[已解决]大佬们，快来救救孩子（邮箱读写）

z5560636

1. import email
   
2. import poplib
   
3. 
   
4. 
   
5. def decode(header: str):
   
6.     value, charset = email.header.decode_header(header)[0]
   
7.     if charset:
   
8.         return str(value, encoding=charset)
   
9.     else:
   
10.         return value
    
11. 
    
12. 
    
13. def download_attachment(msg):
    
14.     subject = decode(msg.get('Subject'))  # 获取消息标题
    
15.     for part in msg.walk():  # 遍历整个msg的内容
    
16.         if part.get_content_disposition() == 'attachment':
    
17.             attachment_name = decode(part.get_filename())  # 获取附件名称
    
18.             attachment_content = part.get_payload(decode=True)  # 下载附件
    
19.             attachment_file = open('./' + attachment_name, 'wb') # 在指定目录下创建文件，注意二进制文件需要用wb模式打开
    
20.             attachment_file.write(attachment_content)  # 将附件保存到本地
    
21.             attachment_file.close()
    
22.     print('Done………………', subject)
    
23. 
    
24. 
    
25. def main():
    
26.     """连接到POP3服务器"""
    
27.     server = poplib.POP3(host='pop.qiye.aliyun.com')  # 创建一个POP3对象，参数host是指定服务器
    
28. 
    
29.     """身份验证"""
    
30.     server.user('*')  # 参数是你的邮箱地址
    
31.     server.pass_('*')  # 参数是你的邮箱密码，如果出现poplib.error_proto: b'-ERR login fail'，就用开启POP3服务时拿到的授权码
    
32. 
    
33.     """获取邮箱中消息（邮件）数量"""
    
34.     msg_count, _ = server.stat()
    
35.     print(msg_count,_)
    
36.     """遍历消息并保存附件"""
    
37.     for i in range(msg_count):
    
38.         """获取消息内容：POP3.retr(which)检索index为which的整个消息，并将其设为已读"""
    
39.         _, lines, _ = server.retr(
    
40.             i+1)  # 3个结果分别是响应结果（1个包含是否请求成功和该消息大小的字符串），消息内容（一个字符串列表，每个元素是消息内容的一行），消息大小（即有多少个octets，octet特指8bit的字节）
    
41. 
    
42.         """将bytes格式的消息内容拼接"""
    
43.         msg_bytes_content = b'\r\n'.join(lines)
    
44.         """将字符串格式的消息内容转换为email模块支持的格式（<class 'email.message.Message'>）"""
    
45.         msg = email.message_from_bytes(msg_bytes_content)
    
46.         """下载消息中的附件"""
    
47.         download_attachment(msg)
    
48. 
    
49. 
    
50. if __name__ == "__main__":
    
51.     main()
    

复制代码

代码能跑通，附件能下载。但是我想被读取下载过附件的邮件，在下次访问的时候不在读取，应该怎么做？  读取邮件的正文，需要怎么做？

最佳答案

月排行榜 / 总排行榜

suchocolate

2021-6-28 12:37:53

加一个文件记录有无下载过

1. import email
   
2. import poplib
   
3. import pickle   # <===== 加pickle模块
   
4. 
   
5. 
   
6. def decode(header: str):
   
7.     value, charset = email.header.decode_header(header)[0]
   
8.     if charset:
   
9.         return str(value, encoding=charset)
   
10.     else:
    
11.         return value
    
12. 
    
13. 
    
14. def download_attachment(msg, db):   # <===== 传入db
    
15.     subject = decode(msg.get('Subject'))  # 获取消息标题
    
16.     for part in msg.walk():  # 遍历整个msg的内容
    
17.         if part.get_content_disposition() == 'attachment':
    
18.             if subject not in db:   # <===== db中没有就下载，有就不下载
    
19.                 attachment_name = decode(part.get_filename())  # 获取附件名称
    
20.                 attachment_content = part.get_payload(decode=True)  # 下载附件
    
21.                 attachment_file = open('./' + attachment_name, 'wb')  # 在指定目录下创建文件，注意二进制文件需要用wb模式打开
    
22.                 attachment_file.write(attachment_content)  # 将附件保存到本地
    
23.                 attachment_file.close()
    
24.                 db.append(subject)   # <===== 下载完后加入到db
    
25.     print('Done………………', subject)
    
26.     return db   # <===== 记得返回db
    
27. 
    
28. 
    
29. def main():
    
30.     """连接到POP3服务器"""
    
31.     server = poplib.POP3(host='pop.qiye.aliyun.com')  # 创建一个POP3对象，参数host是指定服务器
    
32. 
    
33.     """身份验证"""
    
34.     server.user('*')  # 参数是你的邮箱地址
    
35.     server.pass_('*')  # 参数是你的邮箱密码，如果出现poplib.error_proto: b'-ERR login fail'，就用开启POP3服务时拿到的授权码
    
36. 
    
37.     """获取邮箱中消息（邮件）数量"""
    
38.     msg_count, _ = server.stat()
    
39.     print(msg_count, _)
    
40. 
    
41.     db = pickle.load(open("db.pkl", "rb"))   # <===== 打开db文件，没有的话可以提前手工建一个空白列表的pickle文件：pickle.dump([], open("db.pkl", "wb"))
    
42.    
    
43.     """遍历消息并保存附件"""
    
44.     for i in range(msg_count):
    
45.         """获取消息内容：POP3.retr(which)检索index为which的整个消息，并将其设为已读"""
    
46.         _, lines, _ = server.retr(
    
47.             i + 1)  # 3个结果分别是响应结果（1个包含是否请求成功和该消息大小的字符串），消息内容（一个字符串列表，每个元素是消息内容的一行），消息大小（即有多少个octets，octet特指8bit的字节）
    
48. 
    
49.         """将bytes格式的消息内容拼接"""
    
50.         msg_bytes_content = b'\r\n'.join(lines)
    
51.         """将字符串格式的消息内容转换为email模块支持的格式（<class 'email.message.Message'>）"""
    
52.         msg = email.message_from_bytes(msg_bytes_content)
    
53.         """下载消息中的附件"""
    
54.         db = download_attachment(msg, db)   # <===== 传入db
    
55.     pickle.dump(db, open("db.pkl", "wb"))   # <===== 最后保存db
    
56. 
    
57. 
    
58. if __name__ == "__main__":
    
59.     main()
    

复制代码

跳转到最佳答案楼层

suchocolate

加一个文件记录有无下载过

1. import email
   
2. import poplib
   
3. import pickle   # <===== 加pickle模块
   
4. 
   
5. 
   
6. def decode(header: str):
   
7.     value, charset = email.header.decode_header(header)[0]
   
8.     if charset:
   
9.         return str(value, encoding=charset)
   
10.     else:
    
11.         return value
    
12. 
    
13. 
    
14. def download_attachment(msg, db):   # <===== 传入db
    
15.     subject = decode(msg.get('Subject'))  # 获取消息标题
    
16.     for part in msg.walk():  # 遍历整个msg的内容
    
17.         if part.get_content_disposition() == 'attachment':
    
18.             if subject not in db:   # <===== db中没有就下载，有就不下载
    
19.                 attachment_name = decode(part.get_filename())  # 获取附件名称
    
20.                 attachment_content = part.get_payload(decode=True)  # 下载附件
    
21.                 attachment_file = open('./' + attachment_name, 'wb')  # 在指定目录下创建文件，注意二进制文件需要用wb模式打开
    
22.                 attachment_file.write(attachment_content)  # 将附件保存到本地
    
23.                 attachment_file.close()
    
24.                 db.append(subject)   # <===== 下载完后加入到db
    
25.     print('Done………………', subject)
    
26.     return db   # <===== 记得返回db
    
27. 
    
28. 
    
29. def main():
    
30.     """连接到POP3服务器"""
    
31.     server = poplib.POP3(host='pop.qiye.aliyun.com')  # 创建一个POP3对象，参数host是指定服务器
    
32. 
    
33.     """身份验证"""
    
34.     server.user('*')  # 参数是你的邮箱地址
    
35.     server.pass_('*')  # 参数是你的邮箱密码，如果出现poplib.error_proto: b'-ERR login fail'，就用开启POP3服务时拿到的授权码
    
36. 
    
37.     """获取邮箱中消息（邮件）数量"""
    
38.     msg_count, _ = server.stat()
    
39.     print(msg_count, _)
    
40. 
    
41.     db = pickle.load(open("db.pkl", "rb"))   # <===== 打开db文件，没有的话可以提前手工建一个空白列表的pickle文件：pickle.dump([], open("db.pkl", "wb"))
    
42.    
    
43.     """遍历消息并保存附件"""
    
44.     for i in range(msg_count):
    
45.         """获取消息内容：POP3.retr(which)检索index为which的整个消息，并将其设为已读"""
    
46.         _, lines, _ = server.retr(
    
47.             i + 1)  # 3个结果分别是响应结果（1个包含是否请求成功和该消息大小的字符串），消息内容（一个字符串列表，每个元素是消息内容的一行），消息大小（即有多少个octets，octet特指8bit的字节）
    
48. 
    
49.         """将bytes格式的消息内容拼接"""
    
50.         msg_bytes_content = b'\r\n'.join(lines)
    
51.         """将字符串格式的消息内容转换为email模块支持的格式（<class 'email.message.Message'>）"""
    
52.         msg = email.message_from_bytes(msg_bytes_content)
    
53.         """下载消息中的附件"""
    
54.         db = download_attachment(msg, db)   # <===== 传入db
    
55.     pickle.dump(db, open("db.pkl", "wb"))   # <===== 最后保存db
    
56. 
    
57. 
    
58. if __name__ == "__main__":
    
59.     main()
    

复制代码

z5560636

suchocolate 发表于 2021-6-28 12:37
加一个文件记录有无下载过

邮件正文怎么读取？

suchocolate

z5560636 发表于 2021-6-28 12:53
邮件正文怎么读取？

基本功能看教程：https://www.kancloud.cn/thinkphp/python-guide/39542

z5560636

suchocolate 发表于 2021-6-28 12:37
加一个文件记录有无下载过

大佬，有BUG， 我改成 message-id 了，能帮忙解释一下 pickle 的机制吗？

suchocolate

z5560636 发表于 2021-6-28 17:12
大佬，有BUG， 我改成 message-id 了，能帮忙解释一下 pickle 的机制吗？

基本功能看教程：https://www.runoob.com/python3/python3-inputoutput.html