菜谱 5:发送带附件的邮件

我们平时需要使用 Python 发送各类邮件,这个需求怎么来实现?答案其实很简单,smtplib 和email 库可以帮忙实现这个需求。smtplib 和 email 的组合可以用来发送各类邮件:普通文本,HTML 形式,带附件,群发邮件,带图片的邮件等等。我们这里将会分几节把发送邮件功能解释完成。

smtplib 是 Python 用来发送邮件的模块,email 是用来处理邮件消息。

发送带附件的邮件是利用 email.mime.multipart 的 MIMEMultipart 以及 email.mime.image 的 MIMEImage,重点是构造邮件头信息:

#!/usr/bin/env python
# -*- coding: utf-8 -*-

import smtplib
from email.mime.multipart import MIMEMultipart
from email.mime.text import MIMEText

sender = '***'
receiver = '***'
subject = 'python email test'
smtpserver = 'smtp.163.com'
username = '***'
password = '***'

msgRoot = MIMEMultipart('mixed')
msgRoot['Subject'] = 'test message'

# 构造附件
att = MIMEText(open('/Users/1.jpg', 'rb').read(), 'base64', 'utf-8')
att["Content-Type"] = 'application/octet-stream'
att["Content-Disposition"] = 'attachment; filename="1.jpg"'
msgRoot.attach(att)

smtp = smtplib.SMTP()
smtp.connect(smtpserver)
smtp.login(username, password)
smtp.sendmail(sender, receiver, msgRoot.as_string())
smtp.quit()

注意:这里的代码并没有把异常处理加入,需要读者自己处理异常。

阅读全文 »

菜谱 4:发送带图片的邮件

我们平时需要使用 Python 发送各类邮件,这个需求怎么来实现?答案其实很简单,smtplib 和email 库可以帮忙实现这个需求。smtplib 和 email 的组合可以用来发送各类邮件:普通文本,HTML 形式,带附件,群发邮件,带图片的邮件等等。我们这里将会分几节把发送邮件功能解释完成。

smtplib 是 Python 用来发送邮件的模块,email 是用来处理邮件消息。

发送带图片的邮件是利用 email.mime.multipart 的 MIMEMultipart 以及 email.mime.image 的 MIMEImage:

#!/usr/bin/env python
# -*- coding: utf-8 -*-

import smtplib
from email.mime.multipart import MIMEMultipart
from email.mime.text import MIMEText
from email.mime.image import MIMEImage

sender = '***'
receiver = '***'
subject = 'python email test'
smtpserver = 'smtp.163.com'
username = '***'
password = '***'

msgRoot = MIMEMultipart('related')
msgRoot['Subject'] = 'test message'

msgText = MIMEText(
    ''' Some  HTML  text  and an image.good!''', 'html', 'utf-8')
msgRoot.attach(msgText)

fp = open('/Users/1.jpg', 'rb')
msgImage = MIMEImage(fp.read())
fp.close()

msgImage.add_header('Content-ID', '')
msgRoot.attach(msgImage)

smtp = smtplib.SMTP()
smtp.connect(smtpserver)
smtp.login(username, password)
smtp.sendmail(sender, receiver, msgRoot.as_string())
smtp.quit()

注意:这里的代码并没有把异常处理加入,需要读者自己处理异常。

阅读全文 »

菜谱 3:发送 HTML 形式的邮件

我们平时需要使用 Python 发送各类邮件,这个需求怎么来实现?答案其实很简单,smtplib 和email 库可以帮忙实现这个需求。smtplib 和 email 的组合可以用来发送各类邮件:普通文本,HTML 形式,带附件,群发邮件,带图片的邮件等等。我们这里将会分几节把发送邮件功能解释完成。

smtplib 是 Python 用来发送邮件的模块,email 是用来处理邮件消息。

发送 HTML 形式的邮件,需要 email.mime.text 中的 MIMEText 的 _subtype 设置为 html,并且 _text 的内容应该为 HTML 形式。其它的就和 菜谱 2:发送普通文本邮件 一样:

import smtplib
from email.mime.text import MIMEText

sender = '***'
receiver = '***'
subject = 'python email test'
smtpserver = 'smtp.163.com'
username = '***'
password = '***'

msg = MIMEText(u"""
               

你好

""", 'html', 'utf - 8') msg['Subject'] = subject smtp = smtplib.SMTP() smtp.connect(smtpserver) smtp.login(username, password) smtp.sendmail(sender, receiver, msg.as_string()) smtp.quit()

注意:这里的代码并没有把异常处理加入,需要读者自己处理异常。

阅读全文 »

菜谱 2:发送普通文本邮件

我们平时需要使用 Python 发送各类邮件,这个需求怎么来实现?答案其实很简单,smtplib 和email 库可以帮忙实现这个需求。smtplib 和 email 的组合可以用来发送各类邮件:普通文本,HTML 形式,带附件,群发邮件,带图片的邮件等等。我们这里将会分几节把发送邮件功能解释完成。

smtplib 是 Python 用来发送邮件的模块,email 是用来处理邮件消息。

发送普通文本的邮件,只需要 email.mime.text 中的 MIMEText 的 _subtype 设置为 plain。首先导入 smtplib 和 mimetext。创建 smtplib.smtp 实例,connect 邮件 smtp 服务器,login 后发送:

import smtplib
from email.mime.text import MIMEText
from email.header import Header

sender = '***'
receiver = '***'
subject = 'python email test'
smtpserver = 'smtp.163.com'
username = '***'
password = '***'

msg = MIMEText(u'你好','plain','utf-8')#中文需参数‘utf-8',单字节字符不需要
msg['Subject'] = Header(subject, 'utf-8')

smtp = smtplib.SMTP()
smtp.connect(smtpserver)
smtp.login(username, password)
smtp.sendmail(sender, receiver, msg.as_string())
smtp.quit()

注意:这里的代码并没有把异常处理加入,需要读者自己处理异常。

阅读全文 »

菜谱 1:创建一个唯一的 session ID

在网站开发的时候,常常需要生成一个唯一的的会话(session)id,这个会话 id 存储在 cookie 中或者在其它安全的地方。


	# create a unique session id
	# input - string to use as part of the data used to create the session key.
	#         Although not required, it is best if this includes some unique 
	#         data from the site, such as it's IP address or other environment 
	#         information.  For ZOPE applications, pass in the entire ZOPE "REQUEST"
	#         object.
	def makeSessionId(st):
		import md5, time, base64, string
		m = md5.new()
		m.update('this is a test of the emergency broadcasting system')
		m.update(str(time.time()))
		m.update(str(st))
		return string.replace(base64.encodestring(m.digest())[:-3], '/', '$')

	def makeSessionId_nostring(st):
		import md5, time, base64
		m = md5.new()
		m.update('this is a test of the emergency broadcasting system')
		m.update(str(time.time()))
		m.update(str(st))
		return base64.encodestring(m.digest())[:-3].replace('/', '$')
        


输入参数:st,不限制 st 唯一,但是建议传入的 st 是唯一的,可以是 IP 或者一些环境信息。

输出:唯一的 session id 字符串。

阅读全文 »

flask+sqlalchemy+postgresql 异步方案

flask+sqlalchemy+postgresql 异步方案的Github 地址: https://github.com/sixu05202004/async-flask-sqlalchemy-postgresql 使用说明: 安装所需的插件: pip install -r requirements.txt 需要在postgresql中创建数据库 test_asyn 运行 python app.py -c 用来创建测试的表; 运行 python app.py 来启动服务器,运行 python client 来测试 结果如下:: localhost:async-flask-sqlalchemy-postgresql sixu05202004$ python client.py Sending 5 requests for http://localhost:8080/test/postgres/... @ 5.05s got response [200] @ 5.05s got response [200] @ 5.05s got response [200] @ 5.05s got response [200] @ 5.05s got response [200] = 5.06s TOTAL SUM TOTAL = 5.06s 注意: 1.config.py 中需要修改测试数据库的用户名和密码,并且可以修改pool_size的数量; 2.python client.py num,比如:python client.py 100可以用来模拟更多的连接; 3.如果python client.py num中得num数大于config.py中的SQLALCHEMY_POOL_SIZE = 100时候,我们会发现有些数据库连接又存在阻塞的情况。 比如,我们把SQLALCHEMY_POOL_SIZE改成10,使用python client.py 30来测试,结果如下:: localhost:async-flask-sqlalchemy-postgresql sixu05202004$ python client.py 30 Sending 30 requests for http://localhost:8080/test/postgres/... @ 5.07s got response [200] @ 5.07s got response [200] @ 5.08s got response [200] @ 5.09s got response [200] @ 5.09s got response [200] @ 5.13s got response [200] @ 5.12s got response [200] @ 5.12s got response [200] @ 5.13s got response [200] @ 5.19s got response [200] @ 5.19s got response [200] @ 5.19s got response [200] @ 5.19s got response [200] @ 5.19s got response [200] @ 5.19s got response [200] @ 5.19s got response [200] @ 5.19s got response [200] @ 5.20s got response [200] @ 5.20s got response [200] @ 5.20s got response [200] @ 10.14s got response [200] @ 10.15s got response [200] @ 10.15s got response [200] @ 10.24s got response [200] @ 10.24s got response [200] @ 10.24s got response [200] @ 10.24s got response [200] @ 10.25s got response [200] @ 10.25s got response [200] @ 10.26s got response [200] = 10.28s TOTAL SUM TOTAL = 10.28s 这是因为 连接数 》SQLALCHEMY_POOL_SIZE + SQLALCHEMY_MAX_OVERFLOW ,我们可以通过一些设置来避免这种情况(NullPool ),但是实际上 postgresql 规定了最大连接数,这个是无法避免的,因此上述的设置最好不要使用 ...

阅读全文 »

Python中的staticmethod和classmethod以及self和cls

    今日在检查代码的时候,发现其中有四个名词:staticmethod、classmethod、self和cls。怕日后记不清楚了,因此特意记录下来,以便日后翻阅查看,并且可以帮助其他的 Pythoner 们。
  • staticmethod和classmethod

          staticmethod 可以称为“静态方法”,classmethod可以称为“类成员方法”。

          两者的相同点是:都可以通过实例或者类来访问;都不能访问实例的成员变量。

          两者之间不同点有:staticmethod无需参数,classmethod需要类变量作为参数传递(不是类的实例);classmethod可以访问类成员,staticmethod则不可以

          示例:

class a(object):

    @classmethod
    def test(cls):
        return "a.test"


class b(a):
    result = 'here!'

    def __init__(self, t='self here'):
        self.t = t

    def fun1(self):
        print "a.fun1", self
        print self.t, self.result

    @staticmethod
    def fun2():
        print "a.fun2"

    @classmethod
    def fun3(cls):
        print cls.test(), cls
        print cls.result

  • self 和 cls

        self 表示一个实例的本身,cls表示一个类的本身。类中普通的方法,第一个参数需要是self,它表示一个具体的实例本身。

        如果用了staticmethod,那么就可以无视这个self,而将这个方法当成一个普通的函数使用。
        而对于classmethod,它的第一个参数不是self,是cls,它表示这个类本身。

        示例:


class a(object):

    @classmethod
    def test(cls):
        return "a.test"


class b(a):
    result = 'here!'

    def __init__(self, t='self here'):
        self.t = t

    def fun1(self):
        print "a.fun1", self
        print self.t, self.result

    @staticmethod
    def fun2():
        print "a.fun2"

    @classmethod
    def fun3(cls):
        print cls.test(), cls
        print cls.result

if __name__ == '__main__':
    test = b()
    test.fun1()
    test.fun2()
    test.fun3()
    print test.test()



运行结果:

a.fun1 <__main__.b object at 0x0247B810>
self here here!
a.fun2
a.test <class '__main__.b'>
here!
a.test



阅读全文 »

如何在Python中使用Linux epoll

一.简介 在Python2.6中引入了一个访问Linux的epoll的API。本文使用Python3简要地展示一下这个API。 二.阻塞式套接字编程示例 例1是一个简单的Python服务器:它在端口8080上监听HTTP请求消息,并把它打印到控制台,返回给客户端发送一个HTTP响应消息。 * Line 9: 创建服务器套接字。 * Line 10: 在11行上允许 bind(),即使另一个程序最近在同一端口上监听。否则程序无法运行,直到一两分钟后,前面的程序使用该端口已经完成。 * Line 11: 服务器套接字绑定到这台机器上的所有可用的IPv4地址的端口8080上。 * Line 12: 告诉服务器套接字开始从客户端接受传入的连接。 * Line 14: 该程序将会在这里等待着,直到一个连接被接受。当发生这种情况时,服务器套接字将在这台机器上创建一个新的套接字用于与客户端交互。这个新的套接字将会被 accept() 调用的 clientconnection 对象来表示。地址对象表示连接的另一端的IP地址和端口号。 * Lines 15-17: 数据开始在传输直到一个完整的HTTP请求完成。HTTP 协议是在HTTP Made Easy(http://www.jmarshall.com/easy/http/)中有详细的描述。 * Line 18: 为了验证正确的操作,打印请求到控制台。 * Line 19: 发送响应到客户端。 * Lines 20-22: 关闭到客户端的连接以及监听服务器套接字。 官方的 HOWTO (http://docs.python.org/3.0/howto/sockets.html) 对使用 Python 进行套接字编程有着更详细的说明。 Example 1 (All examples use Python 3) 1 import socket 2 3 EOL1 = b'\n\n' 4 EOL2 = b'\n\r\n' 5 response = b'HTTP/1.0 200 OK\r\nDate: Mon, 1 Jan 1996 01:01:01 GMT\r\n' 6 response += b'Content-Type: text/plain\r\nContent-Length: 13\r\n\r\n' 7 response += b'Hello, world!' 8 9 serversocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 10 serversocket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) 11 serversocket.bind(('0.0.0.0', 8080)) 12 serversocket.listen(1) 13 14 connectiontoclient, address = serversocket.accept() 15 request = b'' 16 while EOL1 not in request and EOL2 not in request: 17 request += connectiontoclient.recv(1024) 18 print(request.decode()) 19 connectiontoclient.send(response) 20 connectiontoclient.close() 21 22 serversocket.close() 例2在15行增加了一个循环用来反复处理客户端连接,并由用户(例如,一个键盘中断)中断。这更清楚地说明服务器套接字绝不会被用来与客户端的数据交换。相反,它接受从客户端的连接,然后在服务器计算机上创建一个新的套接字,用于与客户端交互。 在第23-24行上的 finally 语句,确保监听的服务器套接字总是关闭,即使在发生异常的时候。 Example 2 1 import socket 2 3 EOL1 = b'\n\n' 4 EOL2 = b'\n\r\n' 5 response = b'HTTP/1.0 200 OK\r\nDate: Mon, 1 Jan 1996 01:01:01 GMT\r\n' 6 response += b'Content-Type: text/plain\r\nContent-Length: 13\r\n\r\n' 7 response += b'Hello, world!' 8 9 serversocket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 10 serversocket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) 11 serversocket.bind(('0.0.0.0', 8080)) 12 serversocket.listen(1) 13 14 try: 15 while True: 16 connectiontoclient, address = serversocket.accept() 17 request = b'' 18 while EOL1 not in request and EOL2 not in request: 19 request += connectiontoclient.recv(1024) 20 print('-'*40 + '\n' + request.decode()[:-2]) 21 connectiontoclient.send(response) 22 connectiontoclient.close() 23 finally: 24 serversocket.close() 三.异步套接字和Linux epoll的好处 在例2中展示的套接字服务器是阻塞式的,因为程序在等待直到一个事件的发生。在16行的 accept() 调用阻塞着直到一个客户端的连接被接受。19行的 recv() 调用阻塞着直到接收完客户端的数据(或者甚至没有接收到任何数据)。21行的 send() 调用阻塞着直到所有返回给客户端的数据在Linux上已排队准备传输。 当一个程序使用阻塞式套接字,它通常使用一个线程(甚至是专用的进程)与这些套接字进行通信。主程序的线程包含了监听服务器的套接字,它将接受客户端的连接。它将接受所有的客户端连接,并且把新建的套接字分配给一个独立的线程,这些独立的线程将会与客户端进行交互。因为每一个线程单独与一个客户端进行通信,任何堵塞不影响其他线程执行各自的任务。 这种使用多线程的阻塞式的套接字让代码简单明了,但是带 ...

阅读全文 »