转自：http://tkang.blogspot.com/2010/07/thrift-server-client-in-python.html

在编写python的thrift代码时，需要先安装thrift module

$ cd thrift-root/lib/py/
$ sudo python setup.py install

下面是一个python的例子 helloworld.thrift

const string HELLO_IN_KOREAN = "an-nyoung-ha-se-yo"const string HELLO_IN_FRENCH = "bonjour!"const string HELLO_IN_JAPANESE = "konichiwa!"service HelloWorld {void ping(),string sayHello(),string sayMsg(1:string msg)
}

生产代码

$ thrift -r --gen py helloworld.thrift

编写服务器PythonServer.py

#!/usr/bin/env pythonimport sys
sys.path.append('./gen-py')from helloworld import HelloWorld
from helloworld.ttypes import *from thrift.transport import TSocket
from thrift.transport import TTransport
from thrift.protocol import TBinaryProtocol
from thrift.server import TServerimport socketclass HelloWorldHandler:def __init__(self):self.log = {}def ping(self):print "ping()"def sayHello(self):print "sayHello()"return "say hello from " + socket.gethostbyname(socket.gethostname())def sayMsg(self, msg):print "sayMsg(" + msg + ")"return "say " + msg + " from " + socket.gethostbyname(socket.gethostname())handler = HelloWorldHandler()
processor = HelloWorld.Processor(handler)
transport = TSocket.TServerSocket('127.0.0.1',30303)
tfactory = TTransport.TBufferedTransportFactory()
pfactory = TBinaryProtocol.TBinaryProtocolFactory()server = TServer.TSimpleServer(processor, transport, tfactory, pfactory)print "Starting python server..."
server.serve()
print "done!"

编写客户端PythonClient.py

#!/usr/bin/env pythonimport sys
sys.path.append('./gen-py')from helloworld import HelloWorld
from helloworld.ttypes import *
from helloworld.constants import *from thrift import Thrift
from thrift.transport import TSocket
from thrift.transport import TTransport
from thrift.protocol import TBinaryProtocoltry:# Make sockettransport = TSocket.TSocket('127.0.0.1', 30303)# Buffering is critical. Raw sockets are very slowtransport = TTransport.TBufferedTransport(transport)# Wrap in a protocolprotocol = TBinaryProtocol.TBinaryProtocol(transport)# Create a client to use the protocol encoderclient = HelloWorld.Client(protocol)# Connect!transport.open()client.ping()print "ping()"msg = client.sayHello()print msgmsg = client.sayMsg(HELLO_IN_KOREAN)print msgtransport.close()except Thrift.TException, tx:print "%s" % (tx.message)

运行程序

$ python PythonServer.py
$ python PythonClient.py