Zabbix MCP Server

from fastapi import FastAPI, HTTPException from fastapi.middleware.cors import CORSMiddleware from .api import webhook, health from .core.logging import api_logger import uvicorn import os from dotenv import load_dotenv # Load biến môi trường load_dotenv() # Khởi tạo FastAPI app app = FastAPI( title="Zabbix MCP Server", description="Middleware service for Zabbix event analysis using AI", version="1.0.0" ) # Cấu hình CORS app.add_middleware( CORSMiddleware, allow_origins=["*"], allow_credentials=True, allow_methods=["*"], allow_headers=["*"], ) # Include routers app.include_router(webhook.router, prefix="/api/v1", tags=["webhook"]) app.include_router(health.router, prefix="/api/v1", tags=["health"]) @app.on_event("startup") async def startup_event(): """Xử lý sự kiện khi server khởi động""" api_logger.info("Server starting up...") try: # Kiểm tra kết nối các service from .api.health import health_check health_status = await health_check() if health_status["status"] == "unhealthy": api_logger.error("Some services are unhealthy on startup") for service, status in health_status["services"].items(): if status["status"] == "unhealthy": api_logger.error(f"{service}: {status['message']}") except Exception as e: api_logger.error(f"Error during startup: {str(e)}") raise @app.on_event("shutdown") async def shutdown_event(): """Xử lý sự kiện khi server tắt""" api_logger.info("Server shutting down...") @app.get("/") async def root(): """Root endpoint""" return { "message": "Welcome to Zabbix MCP Server", "version": "1.0.0", "docs_url": "/docs" } if __name__ == "__main__": # Lấy cấu hình từ biến môi trường host = os.getenv("HOST", "0.0.0.0") port = int(os.getenv("PORT", 8000)) debug = os.getenv("DEBUG", "false").lower() == "true" # Khởi động server uvicorn.run( "app.main:app", host=host, port=port, reload=debug )