from flask import *

import threading

import service.manager as manager
from init import init_all
from conf.util import *

# from web import app
from router.api import api_bp
from router.page import page_bp

app = Flask(__name__)

# 获取配置对象
conf = get_config_object()

# 注册路由
app.register_blueprint(api_bp,url_prefix='/api')
app.register_blueprint(page_bp)

# 启动
if __name__ == '__main__':
    # 初始化
    init_all()
    
    # 运行Kafka与Spark相关
    manager.start()


    # 运行Web服务
    app.run(host=conf.get('server', 'listen'), port=conf.get('server', 'port'), debug=conf.get('server', 'debug'))