crud.py 286 B

123456789
  1. from database import SessionLocal
  2. from models import DeviceData
  3. async def save_device_data(dtu_id: str, device_id: str, status: str):
  4. db = SessionLocal()
  5. db_data = DeviceData(dtu_id=dtu_id, device_id=device_id, status=status)
  6. db.add(db_data)
  7. db.commit()
  8. db.close()