Exemple de code montrant comment recevoir de nouveaux e-mails à temps en Python

Cet article présente principalement la méthode de programmation Python pour obtenir une acquisition rapide de nouveaux e-mails, impliquant la boîte aux lettres de requête en temps réel Python et les compétences opérationnelles liées à l'acquisition d'e-mails. Les amis dans le besoin peuvent s'y référer

Cet article décrit. la mise en œuvre de la programmation Python avec des exemples Un moyen de recevoir de nouveaux e-mails en temps opportun. Partagez-le avec tout le monde pour votre référence, les détails sont les suivants :

#-*- encoding: utf-8 -*-
import sys
import locale
import poplib
from email import parser
import email
import string
import mysql.connector
import traceback
import datetime
from mysql.connector import errorcode
import time
import re
reload(sys);
sys.setdefaultencoding('utf8');
# 确定运行环境的encoding
__g_codeset = sys.getdefaultencoding()
if "ascii"==__g_codeset:
  __g_codeset = 'utf8';
#
def object2double(obj):
  if(obj==None or obj==""):
    return 0
  else:
    return float(obj)
  #end if
#
def getMailIndex():
  file = open('mailindex.txt',"r");
  lines = file.readlines();
  file.close();
  return int(lines[0]);
#
def setMailIndex(index):
  f = open('mailindex.txt', 'w');
  f.write(index);
  f.close();
#
def utf8_to_mbs(s):
  return s.decode("utf-8").encode(__g_codeset)
#
def utf8_to_gbk(s):
  return s.decode("utf-8").encode('gb2312')
#
def mbs_to_utf8(s):
  return s.decode(__g_codeset).encode("utf-8")
#
def gbk_to_utf8(s):
  return s.decode('gb2312').encode("utf-8")
#
def _queryQuick(cu,sql,tuple):
  try:
    cu.execute(sql,tuple);
    rows = []
    for row in cu:
      rows.append(row)
    #
    return rows
  except:
    print(traceback.format_exc())
  #end
#
#获取信息
def _queryRows(cu,sql):
  try:
    cu.execute(sql)
    rows = []
    for row in cu:
      rows.append(row)
    #
    return rows
  except:
    print(traceback.format_exc())
  #end
#
#是否有新邮件
global hasNewMail;
hasNewMail=True;
#全局已读的邮件数量
global globalMailReaded;
globalMailReaded=getMailIndex()+1;
#获取新邮件
def getNewMail(conn2,cur2):
  try:
    global hasNewMail;
    global globalMailReaded;
    conn2.commit();
    rows=_queryRows(cur2,"select count(*) as message_count from hm_messages where messageaccountid=1");
    message_count=rows[0][0];
    if(hasNewMail):
      print('read mailindex.txt')
      globalMailReaded=getMailIndex()+1;
    #end if
    if(message_count<=globalMailReaded):
      hasNewMail=False;
      #print(&#39;Did not receive new mail,continue wait...&#39;)
      return None;#没新邮件，直接返回
    #end if
    #登陆邮箱
    host = &#39;127.0.0.1&#39;
    username = &#39;username@myserver.net&#39;
    password = &#39;password&#39;
    pop_conn = poplib.POP3(host)
    #print pop_conn.getwelcome()
    pop_conn.user(username);
    pop_conn.pass_(password);
    #Get messages from server:
    messages = [pop_conn.retr(i) for i in range(1, len(pop_conn.list()[1]) + 1)]
    # Concat message pieces:
    messages = ["\n".join(mssg[1]) for mssg in messages]
    #Parse message intom an email object:
    messages = [parser.Parser().parsestr(mssg) for mssg in messages]
    print("get new mail!");
    print pop_conn.stat()
    print(&#39;%s readed mail count is %d,all mail count is: %d&#39;%(datetime.datetime.now().strftime("%y-%m-%d %H:%M:%S"),globalMailReaded,len(messages)))
    message = messages[globalMailReaded];
    subject = message.get(&#39;subject&#39;)
    h = email.Header.Header(subject)
    dh = email.Header.decode_header(h)
    #subject = unicode(dh[0][0], dh[0][1]).encode(&#39;utf8&#39;)
    #print >> f, "Date: ", message["Date"]
    #print >> f, "From: ", email.utils.parseaddr(message.get(&#39;from&#39;))[1]
    #print >> f, "To: ", email.utils.parseaddr(message.get(&#39;to&#39;))[1]
    #print >> f, "Subject: ", subject
    j = 0
    for part in message.walk():
      j = j + 1
      fileName = part.get_filename()
      contentType = part.get_content_type()
      mycode=part.get_content_charset();
      # 保存附件
      if fileName:
        pass;
      elif contentType == &#39;text/plain&#39;:# or contentType == &#39;text/html&#39;:
        #保存正文
        data = part.get_payload(decode=True)
        content=str(data);
        if mycode==&#39;gb2312&#39;:
          content= gbk_to_utf8(content)
        #end if
        content=content.replace(u&#39;\u200d&#39;,&#39;&#39;);
        setMailIndex(str(globalMailReaded));
        hasNewMail=True;
        pop_conn.quit();
        return (content,email.utils.parseaddr(message.get(&#39;from&#39;))[1]);
      #end if
    #end for
  except:
    print("search hmailserver fail,try again");
    return None;
  finally:
    pass;
  #end try
#end def
#连接数据库
conn2 = mysql.connector.connect(user=&#39;root&#39;, password=&#39;password&#39;,host=&#39;127.0.0.1&#39;,database=&#39;hmailserver&#39;,charset=&#39;gb2312&#39;);
cur2 = conn2.cursor();
#只要收到电子邮件，就把这个事件记录在事件库中
#现在就是循环查询邮箱，如果有新邮件就读取，并查询关键词库
while(True):
  mailtuple=getNewMail(conn2,cur2);
  if(mailtuple==None):
    #print(&#39;Did not search MySQL,continue loop...&#39;)
    time.sleep(0.5)
    continue;
  #end if
  (article,origin)=mailtuple;
#end while

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!