一些線上化剛剛起步的部門，并不是所有的數據都是直接推送到服務器的數據庫中，有些數據往往是數據中心通過郵件形式推送的，如果每天接收郵件--下載附件--解壓--合并文件--導入數據庫，對于數據工程師來說，這無疑是瑣碎且沒有技術含量的工作，任誰都不愿意在這種工作上面浪費時間。對于這樣的工作，最適合用代碼自動完成了。

下面就是用 Python 完成下載郵箱附件并解壓的代碼了，如果還需要合并文件，可以查看博客該分類下的另一篇文章。

# coding: utf-8 #!/usr/bin/env python3 # -*- coding: utf-8 -*- import poplib import email import datetime import time # import re from email.parser import Parser from email.header import decode_header from email.utils import parseaddr import zipfile import chardetpoplib._MAXLINE=204800 # 輸入郵件地址, 口令和POP3服務器地址: email = '***************@163.com'#此處填寫郵箱賬號 password = '**********'#此處填寫郵箱密碼 pop3_server = 'pop.163.com' today=datetime.datetime.now() gap=datetime.timedelta(days=1) date=today-gap str_date=date.strftime('%m%d') str_date2=today.strftime('%m%d') file1="回盤業績" file2="_8月預催收業績" file3="全量賬戶報表" filename2=[file1,file2,file3]def decode_str(s):#字符編碼轉換 value, charset = decode_header(s)[0] if charset: value = value.decode(charset) return value def get_att(msg,filename2): import email attachment_files1= [] attachment_files2= [] for part in msg.walk(): file_name = part.get_filename()#獲取附件名稱類型 contType = part.get_content_type() if file_name: h = email.header.Header(file_name) dh = email.header.decode_header(h)#對附件名稱進行解碼 filename = dh[0][0] if dh[0][1]: filename = decode_str(str(filename,dh[0][1]))#將附件名稱可讀化 print(filename) #filename = filename.encode("utf-8")if (filename[3:7] in filename2) or (filename[7:11] in filename2):data = part.get_payload(decode=True)#下載附件 att_file = open(R'E:\\郵件下載\\' + "回盤業績.xlsx", 'wb')attachment_files1.append(filename) att_file.write(data)#保存附件 att_file.close()elif filename[:6] ==filename2[2]:data = part.get_payload(decode=True)#下載附件 att_file = open(R'E:\\郵件下載\\' + filename, 'wb')attachment_files2.append(filename) att_file.write(data)#保存附件 att_file.close()return attachment_files2 # 連接到POP3服務器,有些郵箱服務器需要ssl加密，對于不需要加密的服務器可以使用poplib.POP3() server = poplib.POP3_SSL(pop3_server) server.set_debuglevel(1) # 打印POP3服務器的歡迎文字: print(server.getwelcome().decode('utf-8')) # 身份認證: server.user(email) server.pass_(password) # 返回郵件數量和占用空間: print('Messages: %s. Size: %s' % server.stat()) # list()返回所有郵件的編號: resp, mails, octets = server.list() # 可以查看返回的列表類似[b'1 82923', b'2 2184', ...] print(mails) index = len(mails) f_list2=[] for i in range(index,0,-1): #倒序遍歷郵件 resp, lines, octets = server.retr(i) # lines存儲了郵件的原始文本的每一行, #郵件的原始文本: result=chardet.detect(lines[0])print(result)msg_content = b'\r\n'.join(lines).decode("utf-8","ignore")#"ignore"#解析郵件: msg = Parser().parsestr(msg_content) #獲取郵件時間 date1 = time.strptime(msg.get("Date")[0:24],'%a, %d %b %Y %H:%M:%S') #格式化收件時間 date2 = time.strftime("%m%d", date1)#郵件時間格式轉換 if date2==str_date2: f_list = get_att(msg,filename2)#獲取附件f_list2.append(f_list)elif date2<str_date2:break print(f_list2) for i in f_list2:if len(i)!=0:f = zipfile.ZipFile(R'E:\\郵件下載\\' + i[0],'r')for file in f.namelist():f.extract(file,R'E:\\郵件下載\\excel\\') f.close()else:continue#print_info(msg) server.quit()

總結

以上是生活随笔為你收集整理的获取数据 - 下载附件解压附件 - Python代码的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。