VivianDee
37 lines
1.3 KiB
Python
37 lines
1.3 KiB
Python
import socket
|
|
from fastapi import FastAPI
|
|
from app.salary_analytics.integrations.salary_detect import SalaryDetect
|
|
from app.utils.logger import logger
|
|
|
|
salary_detect = SalaryDetect()
|
|
|
|
|
|
def register_events(app: FastAPI):
|
|
@app.on_event("startup")
|
|
async def startup_event():
|
|
"""Initialize the pipeline on startup."""
|
|
try:
|
|
logger.info("Initializing pipeline...")
|
|
|
|
# Start autonomous salary detection loop
|
|
salary_detect.start()
|
|
logger.info("Started autonomous salary detection loop.")
|
|
|
|
# Print network information
|
|
hostname = socket.gethostname()
|
|
ip_address = socket.gethostbyname(hostname)
|
|
logger.info(f"Server running on hostname: {hostname}")
|
|
logger.info(f"Server IP address: {ip_address}")
|
|
logger.info(f"Server is accessible at:")
|
|
logger.info(f"- http://localhost:8000")
|
|
logger.info(f"- http://127.0.0.1:8000")
|
|
logger.info(f"- http://{ip_address}:8000")
|
|
logger.info("Pipeline initialized successfully")
|
|
except Exception as e:
|
|
logger.error(f"Error during startup: {str(e)}")
|
|
raise
|
|
|
|
@app.on_event("shutdown")
|
|
async def shutdown_event():
|
|
logger.info("Shutting down Salary Analytics API...")
|