takumi-thrift 0.1.2

Thriftpy instruments for passing metadata

Thriftpy instruments for passing metadata bidirectional.

Example

from takumi_thrift import Processor, Response

ping = load('ping.thrift')

class Handler(object):
    def ping_api(self, **kwargs):
        return Response('pong', meta={'server_id': 'test_server'})

# server
from thriftpy.transport import TServerSocket
from thriftpy.server import TSimpleServer

sock = TServerSocket(host='localhost', port=1990)
processor = Processor(ping.PingService, Handler())
server = TSimpleServer(processor, sock)
server.serve()

# client
from thriftpy.transport import TBufferedTransportFactory, TSocket
from thriftpy.protocol import TBinaryProtocolFactory
from takumi_thrift import Client

sock = TScoket(host='localhost', port=1990)
trans = TBufferedTransportFactory().get_transport(sock)
proto = TBinaryProtocolFactory().get_protocol(trans)
trans.open()
client = Client(ping.PingService, proto)
client.ping_api(meta={'hello': 'world', 'client_name': 'test_client'})