def _deliver(self, mailfrom, rcpttos, data):
import smtplib
refused = {}
try:
s = smtplib.SMTP()
s.connect(self._remoteaddr[0], self._remoteaddr[1])
try:
refused = s.sendmail(mailfrom, rcpttos, data)
finally:
s.quit()
except smtplib.SMTPRecipientsRefused, e:
print >> DEBUGSTREAM, 'got SMTPRecipientsRefused'
refused = e.recipients
except (socket.error, smtplib.SMTPException), e:
print >> DEBUGSTREAM, 'got', e.__class__
# All recipients were refused. If the exception had an associated
# error code, use it. Otherwise,fake it with a non-triggering
# exception code.
errcode = getattr(e, 'smtp_code', -1)
errmsg = getattr(e, 'smtp_error', 'ignore')
for r in rcpttos:
refused[r] = (errcode, errmsg)
return refused
python类SMTP的实例源码
def mail(self):
gonderen = "sender e-mail"
pswd = "sender e-mail passwd"
alici = "receiver e mail "
cc = "if you need add cc e-mail "
body=self.mesaj
print(self.mesaj)
try:
server = smtplib.SMTP("smtp.live.com", 587)
server.starttls()
server.login(gonderen, pswd)
server.sendmail(gonderen,[alici,cc],body)
server.close()
print("mail gönderildi")
except smtplib.SMTPException as e:
print(str(e))
def send_email(subject, msg):
import smtplib
message = "From: %s\r\nTo: %s\r\nSubject: %s\r\n\r\n%s\r\n" % (config.EMAIL_HOST_USER, ", ".join(config.EMAIL_RECEIVER), subject, msg)
try:
smtpserver = smtplib.SMTP(config.EMAIL_HOST)
smtpserver.set_debuglevel(0)
smtpserver.ehlo()
smtpserver.starttls()
smtpserver.ehlo
smtpserver.login(config.EMAIL_HOST_USER, config.EMAIL_HOST_PASSWORD)
smtpserver.sendmail(config.EMAIL_HOST_USER, config.EMAIL_RECEIVER, message)
smtpserver.quit()
smtpserver.close()
logging.info("send mail success")
except:
logging.error("send mail failed")
traceback.print_exc()
def send_email(subject, text, to_addr_list=DEFAULT_EMAIL_LIST):
body = string.join(('From: %s' % SENDING_ADDRESS,
'To: %s' % to_addr_list,
'Subject: %s' % subject,
'',
text), '\r\n')
try:
server = smtplib.SMTP('smtp.gmail.com:587') # NOTE: This is the GMAIL SSL port.
server.ehlo() # this line was not required in a previous working version
server.starttls()
server.login(SENDING_ADDRESS, 'gmail_password')
server.sendmail(SENDING_ADDRESS, to_addr_list, body)
server.quit()
print "Email sent successfully!"
except:
return "Email failed to send!"
def init_server(self):
self.logger.info("Initializing SMTP/IMAP servers.")
# PySMS at minimum uses smtp server
try:
if self.ssl:
self.smtp = smtplib.SMTP_SSL(self.smtp_server, self.smtp_port)
else:
self.smtp = smtplib.SMTP(self.smtp_server, self.smtp_port)
self.smtp.starttls()
self.smtp.login(self.address, self.password)
except smtplib.SMTPException:
raise PySMSException("Unable to start smtp server, please check credentials.")
# If responding functionality is enabled
if self.imap_server:
try:
if self.ssl:
self.imap = imaplib.IMAP4_SSL(self.imap_server)
else:
self.imap = imaplib.IMAP4(self.imap_server)
r, data = self.imap.login(self.address, self.password)
if r == "OK":
r, data = self.imap.select(self.imap_mailbox)
if r != "OK":
raise PySMSException("Unable to select mailbox: {0}".format(self.imap_mailbox))
else:
raise PySMSException("Unable to login to IMAP server with given credentials.")
except imaplib.IMAP4.error:
raise PySMSException("Unable to start IMAP server, please check address and SSL/TLS settings.")
cm_service_manager.py 文件源码
项目：cm-automation-scripts-devops-hadoop
作者: atheiman
项目源码
文件源码
阅读 20
收藏 0
点赞 0
评论 0
def rolling_restart(service_rr):
print service_rr
try:
#if service_rr.name.lower() in ['hive', 'hue', 'oozie', 'spark']:
# raise AttributeError("Rolling Restart is not available for '%s' " % service.name.lower())
batch_size = raw_input("Number of worker roles to restart together in a batch \n")
fail_count_threshold = raw_input("Stop rolling restart if more than this number of worker batches fail \n")
options = ["true", "false"] # options for stale config
stale_config_only = select_from_items('option to Restart roles on nodes with stale config?(Default is false) \n', options) # Needs to be a user selection
rr_command = service_rr.rolling_restart(batch_size, fail_count_threshold, None, stale_config_only, None, None, None).wait()
except:
print "WARNING: Rolling Restart is not available for '%s'. Exiting... " % service.name.lower()
print "Executing Restart on service '%s' " % service.name.lower()
rr_command = service.restart().wait()
return rr_command
# Get SMTP server and email sender/receiver info
def send_email_gmail(username, password, email_to, email_from, subject, body, debug=False):
# connect to remote mail server and forward message on
server = smtplib.SMTP("smtp.gmail.com", 587)
message = "From: %s\r\nTo: %s\r\nSubject: %s\r\n\r\n%s" % (email_from, email_to, subject, body)
smtp_sendmail_return = ""
if debug:
server.set_debuglevel(True)
try:
server.ehlo()
server.starttls()
server.login(username,password)
smtp_sendmail_return = server.sendmail(email_from, email_to, message)
except Exception, e:
exception = 'SMTP Exception:\n' + str( e) + '\n' + str( smtp_sendmail_return)
finally:
server.quit()
def _test_mail(self):
try:
if self.mail_port == 465:
smtp = SMTP_SSL(self.mail_host, port=self.mail_port, timeout=2)
else:
smtp = SMTP(self.mail_host, port=self.mail_port, timeout=2)
smtp.login(self.mail_addr, self.mail_pass)
smtp.sendmail(self.mail_addr, (self.mail_addr, ),
'''From:%s\r\nTo:%s\r\nSubject:GeekCloud Mail Test!\r\n\r\n Mail test passed!\r\n''' %
(self.mail_addr, self.mail_addr))
smtp.quit()
return True
except Exception, e:
color_print(e, 'red')
skip = raw_input('????(y/n) [n]? : ')
if skip == 'y':
return True
return False
def _input_smtp(self):
while True:
self.mail_host = raw_input('???SMTP??: ').strip()
mail_port = raw_input('???SMTP?? [25]: ').strip()
self.mail_addr = raw_input('?????: ').strip()
self.mail_pass = raw_input('?????: ').strip()
if mail_port: self.mail_port = int(mail_port)
if self._test_mail():
color_print('\n\t?????????, ??????????\n', 'green')
smtp = raw_input('????? (y/n) [y]: ')
if smtp == 'n':
continue
else:
break
print
def _deliver(self, mailfrom, rcpttos, data):
import smtplib
refused = {}
try:
s = smtplib.SMTP()
s.connect(self._remoteaddr[0], self._remoteaddr[1])
try:
refused = s.sendmail(mailfrom, rcpttos, data)
finally:
s.quit()
except smtplib.SMTPRecipientsRefused, e:
print >> DEBUGSTREAM, 'got SMTPRecipientsRefused'
refused = e.recipients
except (socket.error, smtplib.SMTPException), e:
print >> DEBUGSTREAM, 'got', e.__class__
# All recipients were refused. If the exception had an associated
# error code, use it. Otherwise,fake it with a non-triggering
# exception code.
errcode = getattr(e, 'smtp_code', -1)
errmsg = getattr(e, 'smtp_error', 'ignore')
for r in rcpttos:
refused[r] = (errcode, errmsg)
return refused
def connect(threadName, delay, counter, threadID):
start = threadID * counter
file = open(options.ips,'r')
data = file.readlines()
while counter:
if 0:
thread.exit()
s=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
s.settimeout(2)
try:
connect=s.connect((data[start-counter],port))
print "[+] SMTP server on: " + data[start-counter],
print "[+] Server added to output file!"
logger.write(data[start-counter])
if s.recv(1024):
completed.append(data[start-counter].rstrip())
except socket.timeout:
print "[-] Server non-existant: " + data[start-counter].rstrip()
except socket.error:
print "[+] Server exists! " + data[start-counter].rstrip();
print "[-] But it's not SMTP"
s.close()
time.sleep(delay)
counter -= 1
def sendchk(listindex, host, user, password): # seperated function for checking
try:
smtp = smtplib.SMTP(host)
smtp.login(user, password)
code = smtp.ehlo()[0]
if not (200 <= code <= 299):
code = smtp.helo()[0]
if not (200 <= code <= 299):
raise SMTPHeloError(code, resp)
smtp.sendmail(fromaddr, toaddr, message)
print "\n\t[!] Email Sent Successfully:",host, user, password
print "\t[!] Message Sent Successfully\n"
LSstring = host+":"+user+":"+password+"\n"
nList.append(LSstring) # special list for AMS file ID's
LFile = open(output, "a")
LFile.write(LSstring) # save working host/usr/pass to file
LFile.close()
AMSout = open("AMSlist.txt", "a")
AMSout.write("[Server"+str(nList.index(LSstring))+"]\nName="+str(host)+"\nPort=25\nUserID=User\nBccSize=50\nUserName="+str(user)+"\nPassword="+str(password)+"\nAuthType=0\n\n")
smtp.quit()
except(socket.gaierror, socket.error, socket.herror, smtplib.SMTPException), msg:
print "[-] Login Failed:", host, user, password
pass
def _connect(self, host, port, retry_interval=60.0):
server = None
while server is None:
self.log.info(u"Connecting to SMTP server {0!r} port {1}".format(host, port))
try:
server = yield idiokit.thread(
SMTP, host, port,
ca_certs=self.smtp_ca_certs,
timeout=self.smtp_connection_timeout
)
except (socket.error, smtplib.SMTPException) as exc:
self.log.error(u"Failed connecting to SMTP server: {0}".format(utils.format_exception(exc)))
else:
self.log.info(u"Connected to the SMTP server")
break
self.log.info(u"Retrying SMTP connection in {0:.2f} seconds".format(retry_interval))
yield idiokit.sleep(retry_interval)
idiokit.stop(server)
def get_smtp_server():
"""
Instanciate, configure and return a SMTP or SMTP_SSL instance from
smtplib.
:return: A SMTP instance. The quit() method must be call when all
the calls to sendmail() have been made.
"""
uri = parse_uri(config.get('email', 'uri'))
if uri.scheme.startswith('smtps'):
smtp_server = smtplib.SMTP_SSL(uri.hostname, uri.port)
else:
smtp_server = smtplib.SMTP(uri.hostname, uri.port)
if 'tls' in uri.scheme:
smtp_server.starttls()
if uri.username and uri.password:
smtp_server.login(
urllib.unquote_plus(uri.username),
urllib.unquote_plus(uri.password))
return smtp_server
def send_email_account(remote_server, remote_port, username, password, email_from, email_to, subject, body):
if (remote_server == "smtp.gmail.com"):
send_email_gmail(username, password, email_from, email_to, subject, body)
else:
# connect to remote mail server and forward message on
server = smtplib.SMTP(remote_server, remote_port)
msg = MIMEMultipart()
msg['From'] = email_from
msg['To'] = email_to
msg['Subject'] = subject
msg.attach(MIMEText(body, 'plain'))
smtp_sendmail_return = ""
try:
server.login(username, password)
smtp_sendmail_return = server.sendmail(email_from, email_to, msg.as_string())
except Exception, e:
print 'SMTP Exception:\n' + str( e) + '\n' + str( smtp_sendmail_return)
finally:
server.quit()
def send_email_direct(email_from, email_to, subject, body):
# find the appropiate mail server
domain = email_to.split('@')[1]
remote_server = get_mx_record(domain)
if (remote_server is None):
print "No valid email server could be found for [%s]!" % (email_to)
return
# connect to remote mail server and forward message on
server = smtplib.SMTP(remote_server, 25)
msg = MIMEMultipart()
msg['From'] = email_from
msg['To'] = email_to
msg['Subject'] = subject
msg.attach(MIMEText(body, 'plain'))
smtp_sendmail_return = ""
try:
smtp_sendmail_return = server.sendmail(email_from, email_to, msg.as_string())
except Exception, e:
print 'SMTP Exception:\n' + str( e) + '\n' + str( smtp_sendmail_return)
finally:
server.quit()
def _deliver(self, mailfrom, rcpttos, data):
import smtplib
refused = {}
try:
s = smtplib.SMTP()
s.connect(self._remoteaddr[0], self._remoteaddr[1])
try:
refused = s.sendmail(mailfrom, rcpttos, data)
finally:
s.quit()
except smtplib.SMTPRecipientsRefused, e:
print >> DEBUGSTREAM, 'got SMTPRecipientsRefused'
refused = e.recipients
except (socket.error, smtplib.SMTPException), e:
print >> DEBUGSTREAM, 'got', e.__class__
# All recipients were refused. If the exception had an associated
# error code, use it. Otherwise,fake it with a non-triggering
# exception code.
errcode = getattr(e, 'smtp_code', -1)
errmsg = getattr(e, 'smtp_error', 'ignore')
for r in rcpttos:
refused[r] = (errcode, errmsg)
return refused
def send_mail(msg, config = None):
if not config:
config = g_config
session = smtplib.SMTP(config['HOST'], config['port'])
session.ehlo()
session.starttls()
session.ehlo()
session.login(config['username'], config['pwd'])
headers = ["from: " + config['FROM'], "subject: " + config['SUBJECT'], "to: " + config['TO'], "mime-version: 1.0", "content-type: text/html"]
headers = "\r\n".join(headers)
msg = msg + '\r\n\r\n from ' + hostname + ' \r\n\r\n at ' + cwd
session.sendmail(config['FROM'], config['TO'], headers + "\r\n\r\n" + msg)
def parse_args():
parser = argparse.ArgumentParser(description='Send spoofed email message')
parser.add_argument('--server', type=str,
help='SMTP Server (default localhost)', default="localhost")
parser.add_argument('--port', type=int,
help='SMTP Port (defaut 25)', default=25)
parser.add_argument('--sender', type=str,
help='Sender -> from who we send email', required=True)
parser.add_argument('--to', type=str,
help='Receiver-> to who we send email', required=True)
parser.add_argument('--priority', type=int,
help='Message priority (default 3)', default=3)
parser.add_argument('--reply-to', type=str, help='Reply-To', required=True)
parser.add_argument('--subject', type=str, help='Message subject', required=True)
return parser.parse_args()
def _connect_smtp(self, force=False):
if self.smtp_connection is not None and not force:
return True
try:
logging.debug("Connecting to SMTP server {}:{}".format(
self.host, self.port))
smtp = smtplib.SMTP(self.host, self.port)
if self.username and self.password:
smtp.login(self.username, self.password)
self.smtp_connection = smtp
except Exception as e:
logging.error("Error while connecting to SMTP server: "
"{}".format(str(e)),
exc_info=True)
return False
return True
def _send_email(self, from_addr, to_addrs, msg):
if self._connect_smtp():
try:
try:
self.smtp_connection.sendmail(from_addr, to_addrs, msg)
return
except smtplib.SMTPServerDisconnected as e:
logging.debug("SMTP disconnected: {} - reconnecting".format(str(e)))
if self._connect_smtp(force=True):
self.smtp_connection.sendmail(from_addr, to_addrs, msg)
return
except Exception as e:
logging.error("Error while sending email to {}: "
"{}".format(email_addresses, str(e)),
exc_info=True)
def _connect_smtp(self, force=False):
if self.smtp_connection is not None and not force:
return True
try:
logging.debug("Connecting to SMTP server {}:{}".format(
self.host, self.port))
smtp = smtplib.SMTP(self.host, self.port)
if self.username and self.password:
smtp.login(self.username, self.password)
self.smtp_connection = smtp
except Exception as e:
logging.error("Error while connecting to SMTP server: "
"{}".format(str(e)),
exc_info=True)
return False
return True
def _send_email(self, from_addr, to_addrs, msg):
if self._connect_smtp():
try:
try:
self.smtp_connection.sendmail(from_addr, to_addrs, msg)
return
except smtplib.SMTPServerDisconnected as e:
logging.debug("SMTP disconnected: {} - reconnecting".format(str(e)))
if self._connect_smtp(force=True):
self.smtp_connection.sendmail(from_addr, to_addrs, msg)
return
except Exception as e:
logging.error("Error while sending email to {}: "
"{}".format(email_addresses, str(e)),
exc_info=True)
def flush(self):
if len(self.buffer) > 0:
try:
import smtplib
port = self.mailport
if not port:
port = smtplib.SMTP_PORT
smtp = smtplib.SMTP(self.mailhost, port)
msg = "From: %s\r\nTo: %s\r\nSubject: %s\r\n\r\n" % (self.fromaddr, string.join(self.toaddrs, ","), self.subject)
for record in self.buffer:
s = self.format(record)
msg = msg + s + "\r\n"
smtp.sendmail(self.fromaddr, self.toaddrs, msg)
smtp.quit()
except:
self.handleError(None) # no particular record
self.buffer = []
def mail(self):
gonderen = "sender e-mail"
pswd = "sender e-mail passwd"
alici = "receiver e mail "
cc = "if you need add cc e-mail "
body=self.mesaj
print(self.mesaj)
try:
server = smtplib.SMTP("smtp.live.com", 587)
server.starttls()
server.login(gonderen, pswd)
server.sendmail(gonderen,[alici,cc],body)
server.close()
print("mail gönderildi")
except smtplib.SMTPException as e:
print(str(e))
def _send_mime_text_to_email(self, text, email):
"""
:type text: mime_text.MIMEText
:type email: str
:return:
"""
text['To'] = email
try:
pass
connection = smtplib.SMTP(self._smtp_config['host'])
connection.ehlo()
connection.starttls()
connection.ehlo()
connection.login(self._smtp_config['username'], self._smtp_config['password'])
connection.sendmail(self._smtp_config['sender'], email, text.as_string())
connection.quit()
except smtplib.SMTPException:
self._logger.exception('Unable to send email to address "{}"'.format(email))
alert_io_task.py 文件源码
项目：lustre_task_driven_monitoring_framework
作者: GSI-HPC
项目源码
文件源码
阅读 22
收藏 0
点赞 0
评论 0
def _send_mail(self, args):
if args is None:
raise RuntimeError("Passed argument for send mail is not set!")
if len(args) != 2:
raise RuntimeError("Passed argument for send mail has invalid number of arguments!")
subject = args[0]
text = args[1]
msg = MIMEMultipart()
msg['Subject'] = subject
msg['From'] = self.mail_sender
msg['To'] = ', '.join(self.mail_receiver_list)
msg.attach(MIMEText(text))
msg_string = msg.as_string()
logging.debug(msg_string)
smtp_conn = smtplib.SMTP(self.mail_server)
smtp_conn.sendmail(self.mail_sender, self.mail_receiver_list, msg_string)
smtp_conn.quit()
def send_message(self, email_content):
# ???????
now = datetime.datetime.now()
header = self.smtp_email_header + '[' + str(now.month) + '-' + str(now.day) + ' ' + \
str(now.hour) + ':' + str(now.minute) + ':' + str(now.second) + ']'
msg = MIMEText(email_content, 'plain', 'utf-8')
msg['from'] = self.smtp_from_addr
msg['to'] = self.smtp_to_addr
msg['Subject'] = Header(header, 'utf-8').encode()
# ??
try:
smtp_server = smtplib.SMTP(self.smtp_server_host, self.smtp_server_port)
smtp_server.login(self.smtp_from_addr, self.smtp_server_password)
smtp_server.sendmail(self.smtp_from_addr, [self.smtp_to_addr], msg.as_string())
smtp_server.quit()
except Exception as e:
if log.isEnabledFor(logging.ERROR):
log.error("??????")
log.exception(e)
def send(self, target: str, subject: str, html_content_with_cids: str, inline_png_cids_filenames: {str : str}):
msg = EmailMessage()
msg['Subject'] = subject
msg['From'] = self.sender
msg['To'] = target
msg.set_content('')
msg.add_alternative(
html_content_with_cids, subtype='html'
)
for png_cid in inline_png_cids_filenames:
full_path_to_png = os.path.abspath(os.path.join(
os.path.dirname(__file__), inline_png_cids_filenames[png_cid]
))
with open(full_path_to_png, 'rb') as png_file:
file_contents = png_file.read()
msg.get_payload()[1].add_related(file_contents, 'image', 'png', cid=png_cid)
with smtplib.SMTP(self.smtp_server_host, self.smtp_server_port) as smtp_connection:
smtp_connection.starttls()
smtp_connection.login(self.username, self.password)
smtp_connection.send_message(msg)
message_users.py 文件源码
项目：30-Days-of-Python
作者: codingforentrepreneurs
项目源码
文件源码
阅读 24
收藏 0
点赞 0
评论 0
def send_email(self):
self.make_messages()
if len(self.email_messages) > 0:
for detail in self.email_messages:
user_email = detail['email']
user_message = detail['message']
try:
email_conn = smtplib.SMTP(host, port)
email_conn.ehlo()
email_conn.starttls()
email_conn.login(username, password)
the_msg = MIMEMultipart("alternative")
the_msg['Subject'] = "Billing Update!"
the_msg["From"] = from_email
the_msg["To"] = user_email
part_1 = MIMEText(user_message, 'plain')
the_msg.attach(part_1)
email_conn.sendmail(from_email, [user_email], the_msg.as_string())
email_conn.quit()
except smtplib.SMTPException:
print("error sending message")
return True
return False
