def __init__(self, configRoot='.'):
self.__configDir = configRoot+'/.leafd/'
self.__configFname = self.__configDir+'config.yaml'
self.logger = Logger.Logger('LeafService')
if not os.path.exists(self.__configDir):
os.makedirs(self.__configDir)
self.__configure()
self.service = Flask('Leaf')
self.api = Api(self.service)
got_request_exception.connect(logException, self.service)
self.api.add_resource(Info.Config, '/config')
self.api.add_resource(Info.Status, '/status')
self.api.add_resource(Jobs.JobIndex, '/jobs/')
self.api.add_resource(Jobs.JobResource, '/jobs/<int:jobId>')
t = threading.Thread(name='Leaf service', target=appThread,
args=(self.service,Info.configStorage['port']))
t.start()
time.sleep(1)
self.__register()
t.join()
评论列表
文章目录