python 自动下载阿里邮箱中已转入其他文件中的邮件的附件

Question

背景：需自动下载阿里邮箱中附件，自己测试已经完成能够下载，但是邮箱中部分邮件设置在其他文件夹，无法下载。

问题相关代码

# -*- coding: utf-8 -*-
import poplib,email,telnetlib
import datetime,time,sys,traceback
from email.parser import Parser
from email.header import decode_header
from email.utils import parseaddr
import pandas as pd
import numpy as np
import re
class down_email():

    def __init__(self,user,password,eamil_server,fund_name,file_type):
        # 输入邮件地址, 口令和POP3服务器地址:
        self.user = user
        # 此处密码是授权码,用于登录第三方邮件客户端
        self.password = password
        self.pop3_server = eamil_server
        self.fund_name=fund_name
        self.file_type=file_type
    # 获得msg的编码
    def guess_charset(self,msg):
        charset = msg.get_charset()
        if charset is None:
            content_type = msg.get('Content-Type', '').lower()
            pos = content_type.find('charset=')
            if pos >= 0:
                charset = content_type[pos + 8:].strip()
        return charset

    #获取邮件内容
    def get_content(self,msg):
        content=''
        content_type = msg.get_content_type()
        # print('content_type:',content_type)
        if content_type == 'text/plain': # or content_type == 'text/html'
            content = msg.get_payload(decode=True)
            charset = self.guess_charset(msg)
            if charset:
                content = content.decode(charset)
        return content

    # 字符编码转换
    # @staticmethod
    def decode_str(self,str_in):
        value, charset = decode_header(str_in)[0]
        if charset=='gb2312':
            charset='gbk'
            value = value.decode(charset)
        else:
            value = value.decode(charset)
        return value

    # 解析邮件,获取附件
    def get_att(self,msg_in, str_day):
        attachment_files = []
        for part in msg_in.walk():
            # 获取附件名称类型
            file_name = part.get_param("name")  # 如果是附件，这里就会取出附件的文件名
            # file_name = part.get_filename() #获取file_name的第2中方法
            # 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 = self.decode_str(str(filename, dh[0][1]))
                    # print(filename)
                    # filename = filename.encode("utf-8")
                # 下载附件
                data = part.get_payload(decode=True)
                # 在指定目录下创建文件，注意二进制文件需要用wb模式打开
                att_file = open('./test/' + filename, 'wb')
                att_file.write(data)  # 保存附件
                att_file.close()
                attachment_files.append(filename)
            else:
                pass
                # 不是附件，是文本内容
                # print(self.get_content(part)) #输出邮件类容
                # # 如果ture的话内容是没用的
                # if not part.is_multipart():
                #     # 解码出文本内容，直接输出来就可以了。
                #     print(part.get_payload(decode=True).decode('utf-8'))

        return attachment_files

    # 获取已经下载的数据
    def get_data(self,attach_file_all):
        values_list = []
        for item in attach_file_all:
            list_temp = []
            try:
                data = pd.read_excel('./test/' +item, engine='openpyxl', header=0, dtype=str)
            except Exception:
                data = pd.read_excel('./test/' +item, header=0, dtype=str)
            # 找到单位净值
            for item1 in data.columns:
                df_temp = data[data[item1].str.contains('^单位净值', na=False)]
                if len(df_temp) >= 1:
                    for item2 in df_temp.values[0]:
                        if re.match('^单位净值', str(item2)):
                            dwjz = item2.split('：')[1]
                            break
                    break
            # 找到累计单位净值
            for item1 in data.columns:
                df_temp = data[data[item1].str.contains('累计单位净值', na=False)]
                if len(df_temp) >= 1:
                    for i1 in range(0, len(df_temp.values[0])):
                        if re.search('累计单位净值', str(df_temp.values[0][i1])):
                            ljdwjz = df_temp.values[0][i1 + 1]
                            break
                    break
            list_temp.append(dwjz)
            list_temp.append(ljdwjz)
            values_list.append(list_temp)
        df0 = pd.DataFrame(values_list, columns=["单位净值", "累计单位净值"])
        return df0
    # def get_data(self,attach_file_all):
    #     for item in attach_file_all:
    #         try:
    #             data=pd.read_excel('./test/' + item,engine='openpyxl')
    #
    #         except:
    #             print('该文件不是xlx或xlsx格式')
    def run_ing(self): #主程序
        attach_file_all=[]
        str_day = str(datetime.date.today())# 日期赋值
        # 连接到POP3服务器,有些邮箱服务器需要ssl加密，可以使用poplib.POP3_SSL
        try:
            telnetlib.Telnet(self.pop3_server, 995)
            self.server = poplib.POP3_SSL(self.pop3_server, 995, timeout=10)
        except:
            time.sleep(5)
            self.server = poplib.POP3(self.pop3_server, 110, timeout=10)

        # server.set_debuglevel(1) # 可以打开或关闭调试信息
        # 打印POP3服务器的欢迎文字:
        print(self.server.getwelcome().decode('utf-8'))
        # 身份认证:

        self.server.user(self.user)
        self.server.pass_(self.password)
        # 返回邮件数量和占用空间:
        print('Messages: %s. Size: %s' % self.server.stat())
        # list()返回所有邮件的编号:
        resp, mails, octets = self.server.list()
        # 可以查看返回的列表类似[b'1 82923', b'2 2184', ...]
        # print(mails)
        index = len(mails)
        for i in range(index, 0, -1):# 倒序遍历邮件
        # for i in range(1, index + 1):# 顺序遍历邮件
            resp, lines, octets = self.server.retr(i)
            # lines存储了邮件的原始文本的每一行,
            # 邮件的原始文本:
            msg_content = b'\r\n'.join(lines).decode('utf-8')
            # 解析邮件:
            msg = Parser().parsestr(msg_content)
            #获取邮件的发件人，收件人， 抄送人,主题
            # hdr, addr = parseaddr(msg.get('From'))
            # From = self.decode_str(hdr)
            # hdr, addr = parseaddr(msg.get('To'))
            # To = self.decode_str(hdr)
            # 方法2：from or Form均可
            From = parseaddr(msg.get('from'))[1]
            To = parseaddr(msg.get('To'))[1]
            Cc=parseaddr(msg.get_all('Cc'))[1]# 抄送人
            Subject = self.decode_str(msg.get('Subject'))
            print('from:%s,to:%s,Cc:%s,subject:%s'%(From,To,Cc,Subject))
            # 获取邮件时间,格式化收件时间
            print('运行次数',i)
            # print(msg.get("Date"))
            # try:
            #     date1 = time.strptime(msg.get("Date")[0:24], '%a, %d %b %Y %H:%M:%S')
            # except:
            #     date1 = time.strptime(msg.get("Date")[0:11], '%d %b %Y')
            # print(date1)
            # # 邮件时间格式转换
            # date2 = time.strftime("%Y-%m-%d",date1)
            regex_list = ["(\d{4}-\d{1,2}-\d{1,2})", "(\d{4}\d{1,2}\d{1,2})"]
            for regex in regex_list:
                date1 = re.search(regex, Subject)
                if date1:
                    date1 = date1.group(1)
                    try:
                        date1= time.strptime(date1, "%Y%m%d")
                        date1 = time.strftime("%Y-%m-%d", date1)
                    except Exception:
                        date1 = time.strptime(date1, "%Y-%m-%d")
                        date1 = time.strftime("%Y-%m-%d", date1)
                    break
            print('date1:',str(date1))
            if date1==None:
                continue
            print(str(date1))
            str_day='2022-02-15'
            if date1 < str_day:
                break # 倒叙用break
                # continue # 顺叙用continue
            else:
                # 获取附件,条件为 满足 关键词、满足日期、满足类型
                if re.search(self.fund_name,Subject) and re.search(self.file_type,Subject) and date1>str_day:
                    attach_file=self.get_att(msg,str_day)
                    attach_file_all=attach_file_all+attach_file
                    print(attach_file)

        # 可以根据邮件索引号直接从服务器删除邮件:
        # self.server.dele(7)
        print('运行到这')
        try:
            self.server.quit()
        except:
            print('未知原因，quit()报错,我找了找不出来')
        print('所有邮件名称',attach_file_all)
        return attach_file_all #返回所有附件名称


if __name__ == '__main__':
    #把打印内容输出到文件
    # origin = sys.stdout
    # f = open('./test/log.txt', 'w')
    # sys.stdout = f
    try:
        # 输入邮件地址, 口令和POP3服务器地址:
        user = ''
        # 此处密码是授权码,用于登录第三方邮件客户端
        password = ''
        eamil_server = 'pop.qiye.aliyun.com'
        fund_name='南方基金'
        file_type='估值表'
        # user='xinfei@.com'
        # password = 'f67h2'
        # eamil_server = 'pop.qiye.aliyun.com'
        email_class=down_email(user=user,password=password,eamil_server=eamil_server,fund_name=fund_name,file_type=file_type)
        attach_file_all=email_class.run_ing()
        email_class.get_data(attach_file_all)
    except Exception as e:
        # import tracebackA
        ex_msg = '{exception}'.format(exception=traceback.format_exc())
        print(ex_msg)
        # traceback.print_exc()
    # sys.stdout = origin
    # f.close()

运行结果及报错内容

运行没有报错，就是无法下载到已经转移到其他文件夹中的邮件

我的解答思路和尝试过的方法

我想要达到的结果

能够下载转到其他文件夹中的邮件的附件

Answer 1

相关的imaplib的环境，使用的IMAP的模式来进行管理。POP3 是表示仅下载邮件，并不具备管理文件夹的权限。
然后你可以使用IMAP4 就是正常的模式 ，不带有SSL方式进行操作。就是m=imaplib.IMAP4(‘imap服务器地址’)也可以使用SSL的模式 ,m=imaplib.IMAP4_SSL(‘IMAP服务器地址’)
即使已经连接到了服务器,那么你就可以进行登陆验证了。可以使用m=imaplib.login(‘用户名’,’密码’)进行登陆。提示login completed表示登陆成功！
.如果有imaplib.error表示登陆失败了！
登陆成功则可以进行相关的文件夹管理了。m.list() 则可以直接查看到现在有 那些文件夹了。
下面可以直接使用for 语句直接循环出来。
可以使用m.create(‘文件夹名称’)进行创建
.m.delete(‘文件夹名称’)进行删除
可以做一个进行文件夹权限管理。