CameraMachine/python/index.py

import asyncio
import sys
import uvicorn
import signal
from api import *
from sockets.socket_server import *
import uvicorn.loops.auto
import uvicorn.protocols.http.auto
import uvicorn.protocols.websockets.auto
import uvicorn.lifespan.on
from multiprocessing import Process, freeze_support
from service.init_load_source import init_load_source


def handle_shutdown(signum, frame):
    """关闭系统应用服务"""
     # 终止事件循环
    loop = asyncio.get_event_loop()
    loop.call_soon_threadsafe(loop.stop)
    sys.exit(0)

async def run_server():
    # 启动uvicorn服务器
    config = uvicorn.Config(
        APP_RUN,
        host=APP_HOST,
        port=int(PORT),
        reload=isDebug,
        workers=int(APP_WORKS),
    )
    server = uvicorn.Server(config)
    await server.serve()

async def main():
    # 创建后台任务
    task = asyncio.create_task(init_load_source().load_source())
    # 启动服务器
    print(">>>>>>>>>>>>>>>>>>>>>>>>>>")
    await run_server()



if __name__ == "__main__":
    signal.signal(signal.SIGINT, handle_shutdown)
    signal.signal(signal.SIGTERM, handle_shutdown)
    print("python server is running at port:", PORT)
    print("python server is running at port:", APP_RUN)
    isDebug = True if IS_DEBUG == "true" else False
    asyncio.run(main())