Поэтому я явно завершаю работу сервера FastAPI, когда внутри «task_func» возникает ошибка. Использование:
Код: Выделить всё
os.kill(os.getpid(), signal.SIGTERM)
Код Python:
Код: Выделить всё
app = FastAPI()
@app.on_event("startup")
async def startup_event() -> None:
"""Starts processing"""
logging.info("VP: Starting Server")
task = asyncio.create_task(task_func())
try:
await task
except Exception as error:
logging.error(f"Following exception has occured: {error}")
logging.info("Exception has occured. Shutting down uvicron server")
# Terminating FastAPI instance
os.kill(os.getpid(), signal.SIGTERM)
@app.on_event("shutdown")
async def shutdown_event() -> None:
"""Shuts down the app."""
logging.info("Shutting down")
Код: Выделить всё
docker-compose.yml
Код: Выделить всё
events_consumer:
restart: always
build:
context: ./events_consumer
target: dev
Подробнее здесь: https://stackoverflow.com/questions/783 ... terminated