| #!/usr/bin/env python |
| import sys |
| import time |
| from thrift.transport import TTransport |
| from thrift.transport import TSocket |
| from thrift.protocol import TBinaryProtocol |
| from thrift.server import THttpServer |
| from aggr import Aggr |
| |
| class AggrHandler(Aggr.Iface): |
| def __init__(self): |
| self.values = [] |
| |
| def addValue(self, value): |
| self.values.append(value) |
| |
| def getValues(self, ): |
| time.sleep(1) |
| return self.values |
| |
| processor = Aggr.Processor(AggrHandler()) |
| pfactory = TBinaryProtocol.TBinaryProtocolFactory() |
| THttpServer.THttpServer(processor, ('', int(sys.argv[1])), pfactory).serve() |
