In below code snippet, I am trying to make a non-blocking thrift server in python.
# set handler to our implementation
handler = ServiceHandler()
processor = MyService.Processor(handler)
transport = TSocket.TServerSocket(port=port)
tfactory = TTransport.TFramedTransport(transport)
pfactory = TBinaryProtocol.TBinaryProtocolFactory()
# set server
server = TServer.TThreadedServer(processor, transport, tfactory, pfactory)
print 'Python Server has started listening on port ' + str(port)
print '################################################'
server.serve()
I am getting the following error when the python client attempts to connect the server having tyhe above code snippet. Could you please tell me what can be causing this error? Probably I am missing something.
Exception in thread Thread-1:
Traceback (most recent call last):
File "/usr/lib64/python2.6/threading.py", line 522, in __bootstrap_inner
self.run()
File "/usr/lib64/python2.6/threading.py", line 477, in run
self.__target(*self.__args, **self.__kwargs)
File "/usr/local/lib64/python2.6/site-packages/thrift/server/TServer.py", line 114, in handle
itrans = self.inputTransportFactory.getTransport(client)
AttributeError: TFramedTransport instance has no attribute 'getTransport'
I found some working Thrift code and it looks like your tfactory needs to be a TBufferedTransportFactory and not a TBufferedTransport instance.
tfactory = TTransport.TBufferedTransportFactory()
If you love us? You can donate to us via Paypal or buy me a coffee so we can maintain and grow! Thank you!
Donate Us With