-
Notifications
You must be signed in to change notification settings - Fork 0
/
server.py
31 lines (25 loc) · 1019 Bytes
/
server.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
from thrift.protocol import TBinaryProtocol
from thrift.server import TServer
from thrift.transport import TSocket, TTransport
from thrifts.services.types.ttypes import UserInfo
from thrifts.services.user import UserService
from thrifts.services.user.ttypes import GetUserByIdResponse, User
class UserServiceImpl:
def __init__(self):
print("UserService Created")
def get_user_by_id(self, ids):
print("get_user_by_id")
users = [
User(id="1", info=UserInfo(first_name="aha", last_name="oho"))
]
return GetUserByIdResponse(users=users)
userServiceImpl = UserServiceImpl()
processor = UserService.Processor(userServiceImpl)
transport = TSocket.TServerSocket(host="localhost", port=9090)
transport_factory = TTransport.TBufferedTransportFactory()
protocol_factory = TBinaryProtocol.TBinaryProtocolFactory()
server = TServer.TThreadedServer(
processor, transport, transport_factory, protocol_factory)
print("Starting server")
server.serve()
print("Done")