update email

eda/smart_rank/dist_update_portrait_market.py

@@ -22,11 +22,11 @@ from pyspark.sql.functions import concat_ws
 def send_email(app,id,e):
     # 第三方 SMTP 服务
     mail_host = 'smtp.exmail.qq.com'  # 设置服务器
-    mail_user = "gaoyazhe@igengmei.com"  # 用户名
-    mail_pass = "VCrKTui99a7ALhiK"  # 口令
+    mail_user = "zhaowei@igengmei.com"  # 用户名
+    mail_pass = "Gengmei1234"  # 口令
 
-    sender = 'gaoyazhe@igengmei.com'
-    receivers = ['gaoyazhe@igengmei.com']  # 接收邮件，可设置为你的QQ邮箱或者其他邮箱
+    sender = 'zhaowei@igengmei.com'
+    receivers = ['zhaowei@igengmei.com']  # 接收邮件，可设置为你的QQ邮箱或者其他邮箱
     e = str(e)
     msg = MIMEMultipart()
     part = MIMEText('app_id:'+id+':fail', 'plain', 'utf-8')
@@ -37,12 +37,16 @@ def send_email(app,id,e):
     # message['Cc'] = ";".join(cc_reciver)
 
     msg['Subject'] = 'spark streaming:app_name:'+app
-    with open('error.txt','w') as f:
-         f.write(e)
-         f.close()
-    part = MIMEApplication(open('error.txt', 'r').read())
-    part.add_header('Content-Disposition', 'attachment', filename="error.txt")
-    msg.attach(part)
+
+    try:
+        with open('error.txt','w') as f:
+             f.write(e)
+             f.close()
+        part = MIMEApplication(open('error.txt', 'r').read())
+        part.add_header('Content-Disposition', 'attachment', filename="error.txt")
+        msg.attach(part)
+    except Exception as e:
+        print(e)
 
     try:
         smtpObj = smtplib.SMTP_SSL(mail_host, 465)