#!/usr/bin/python
#?-*-?coding:?utf-8?-*-
import?smtplib
from?email.mime.multipart?import?MIMEMultipart
from?email.mime.text?import?MIMEText
from?email.mime.application?import?MIMEApplication
from?email.mime.image?import?MIMEImage
from?email.Header?import?Header
from?email.utils?import?formataddr?parseaddr
from?email?import?encoders

import?traceback
import?os

import?sys

reload（sys）
sys.setdefaultencoding（‘utf8‘）


def?_format_addr（s）:
????name?addr?=?parseaddr（s）
????print?name?addr
????return?formataddr（（Header（name?‘utf-8‘）.encode（）
???????????????????????addr.encode（‘utf-8‘）?if?isinstance（addr?unicode）?else?addr））


def?send_mail（subject?content?sender=‘改成你的發件郵箱.cn‘?receiver=‘改成你的收件郵箱‘?cc=[]?partname=None
??????????????priority=‘0‘）:
????if?type（receiver）?==?str:
????????receiver?=?[receiver]
????receiver1?=?list（receiver）
????msgRoot?=?MIMEMultipart（‘related‘）
????msgRoot[‘From‘]?=?_format_addr（u‘mail監控通知<%s>‘?%?sender）
????msgRoot[‘To‘]?=?‘?‘.join（receiver1）
????msgRoot[‘X-Priority‘]?=?priority
????if?cc:
????????if?type（cc）?==?str:
????????????cc?=?[cc]
????????receiver1.extend（cc）
????????msgRoot[‘Cc‘]?=?‘?‘.join（cc）
????msgRoot[‘Subject‘]?=?subject

????msgText?=?MIMEText（content?‘html‘?‘utf-8‘）
????msgRoot.attach（msgText）

????if?partname:
????????print?partname
????????part?=?MIMEApplication（open（partname?‘rb‘）.read（））
????????part.add_header（‘Content-Disposition‘?‘attachment‘?filename=partname）
????????msgRoot.attach（part）

????smtp?=?None
????try:
????????#?一般都是企業郵箱?個人郵箱我沒有試過?可能會限制什么的
????????smtp?=?smtplib.SMTP_SSL（）
????????smtp.connect（‘smtp.exmail.qq.com‘?port=465）
????????smtp.login（‘改成你的發件郵箱登錄名稱‘?‘改成你的登錄密碼‘）
????????smtp.sendmail（sender?receiver1?msgRoot.as_string（））
????except:
????????print?“sendmail“
????finally:
????????try:
????????????if?smtp:?smtp.quit（）
????????except:
????????????print?“sendmail“


def?isRunning（process_name）:
????try:
????????process?=?len（os.popen（‘ps?aux?|?grep?“‘?+?process_name?+?‘“?|?grep?-v?grep‘）.readlines（））
????????if?process?>=?1:
????????????return?True
????????else:
????????????return?False
????except:
????????print（“Check?process?ERROR!!!“）
????????return?False


def?yarn_mon（result）:
????#該處應該寫絕對路徑
????jps?=?‘/data/module/hadoop-2.7.6/bin/yarn?application?-list‘
????try:
????????yarn_appname=[]
????????yarn_list?=?os.popen（jps）.readlines（）[2:]

????????for?yarn?in?yarn_list:
????????????ys?=?yarn.split（“\t“）[1]
????????????yarn_appname.append（ys）
????????for?job?in?result:
????????????if?job?not?in?yarn_appname:
????????????????print?“send_mail“
????????????????send_mail（“每半小時yarn?spark?job?和?kafka?to?gp?監控“?“每半小時yarn?spark?job監控，該{}任務監控不到，\n“
??????????????????????????????????????????????????“檢查hadoop:8088界面詳情正在運行的job任務為{}:\n“.format（jobyarn_appname））
????except?baseException??e:
????????print?e.message
????????send_mail（“每半小時yarn?spark?job?和?kafka?to?gp?監控“?“30分鐘yarn?spark?job監控，監控郵件Except?未能成功運行?{}“?.format（e.message））

if?__name__?==?‘__main__‘:
????#?監控進

?屬性????????????大小?????日期????時間???名稱
-----------?---------??----------?-----??----
?????文件????????4206??2019-01-29?14:48??mon.py
?????目錄???????????0??2019-01-29?14:56??__MACOSX\
?????文件?????????266??2019-01-29?14:48??__MACOSX\._mon.py
?????文件??????????74??2019-01-29?14:48??mon_yarn_job.txt
?????文件?????????210??2019-01-29?14:48??__MACOSX\._mon_yarn_job.txt
?????文件?????????294??2019-01-29?14:53??閮ㄧ講鏂規硶.py
?????文件?????????210??2019-01-29?14:53??__MACOSX\._閮ㄧ講鏂規硶.py