6

我正在使用 thrift 编写 python 客户端,但我找不到任何可用的选项来设置 rpc 超时。

我的客户端代码如下:

socket = TSocket.TSocket(address, port)
transport = TTransport.TBufferedTransport(socket)
protocol = TBinaryProtocol.TBinaryProtocol(transport)
server = Client.Client(protocol)
transport.open()
4

1 回答 1

13

你可以使用socket.setTimeout()方法。

from thrift.transport.THttpClient import THttpClient
socket = THttpClient(server_url)
socket.setTimeout(SERVICE_TIMEOUT_IN_mS)
transport = TTransport.TBufferedTransport(socket)
protocol = TBinaryProtocol.TBinaryProtocol(transport)
于 2012-10-05T04:59:08.577 回答