Commit b1082fdb authored by wanliofficial's avatar wanliofficial

🐞 fix(框架集成monitor,数据库文件增加sort字段):

parent 4e0be554
This diff is collapsed.
'''
Author: your name
Date: 2021-07-15 09:33:39
LastEditTime: 2021-07-28 19:56:22
LastEditors: your name
Description: In User Settings Edit
FilePath: \evm-store\tools\build_out\manager.py
'''
'''
Author: your name
Date: 2021-06-15 17:40:09
LastEditTime: 2021-06-30 18:09:51
LastEditors: Please set LastEditors
Description: In User Settings Edit
FilePath: \evm-store\tools\resources\manager.py
'''
# -*- coding: utf-8 -*- # -*- coding: utf-8 -*-
from tornado.wsgi import WSGIContainer from tornado.wsgi import WSGIContainer
from tornado.httpserver import HTTPServer from tornado.httpserver import HTTPServer
from tornado.web import Application, RequestHandler, FallbackHandler
from tornado.ioloop import IOLoop from tornado.ioloop import IOLoop
from flask_script import Manager from flask_script import Manager
from flask_migrate import Migrate from flask_migrate import Migrate
from application.app import create_app, db from application.app import create_app, db
from application.config import config from application.config import config
from views.monitor import DeviceMessageHandler, WatchHandler, NotifyHandler
# 根据配置初始化app # 根据配置初始化app
app = create_app(config) app = create_app(config)
...@@ -38,7 +24,6 @@ def run(): ...@@ -38,7 +24,6 @@ def run():
To use: python3 manager.py run To use: python3 manager.py run
""" """
# app.logger.setLevel(app.config.get('LOG_LEVEL', logging.INFO)) # app.logger.setLevel(app.config.get('LOG_LEVEL', logging.INFO))
http_server = HTTPServer(WSGIContainer(app)) http_server = HTTPServer(WSGIContainer(app))
http_server.listen(int(port), address=host) http_server.listen(int(port), address=host)
IOLoop.instance().start() IOLoop.instance().start()
...@@ -49,8 +34,22 @@ def debug(): ...@@ -49,8 +34,22 @@ def debug():
debug模式启动命令函数 debug模式启动命令函数
To use: python3 manager.py debug To use: python3 manager.py debug
""" """
wsgi_app = WSGIContainer(app)
application = Application([
(r"/api/v1/evm_store/monitor", DeviceMessageHandler),
(r"/api/v1/evm_store/watch", WatchHandler),
(r"/ws/v1/notify", NotifyHandler),
(r'.*', FallbackHandler, dict(fallback=wsgi_app))
])
application.listen(int(port), address=host)
IOLoop.current().start()
print("WebSocket Service Started......")
# app.logger.setLevel(logging.DEBUG) # app.logger.setLevel(logging.DEBUG)
app.run(debug=True, port=int(port), host=host) # app.run(debug=True, port=int(port), host=host)
if __name__ == '__main__': if __name__ == '__main__':
manager.run() manager.run()
...@@ -354,3 +354,4 @@ if __name__ == "__main__": ...@@ -354,3 +354,4 @@ if __name__ == "__main__":
signal.signal(signal.SIGTERM, raise_graceful_exit) signal.signal(signal.SIGTERM, raise_graceful_exit)
tornado.ioloop.IOLoop.current().start() tornado.ioloop.IOLoop.current().start()
print("WebSocket Service Started......")
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment