from database import SessionLocal
from models import DeviceData

async def save_device_data(dtu_id: str, device_id: str, status: str):
    db = SessionLocal()
    db_data = DeviceData(dtu_id=dtu_id, device_id=device_id, status=status)
    db.add(db_data)
    db.commit()
    db.close()