Spaces:
Runtime error
Runtime error
File size: 3,371 Bytes
4cea933 0b2f8bd 6046b02 4cea933 0b2f8bd 4cea933 0b2f8bd 4cea933 0b2f8bd 4cea933 0b2f8bd 4cea933 0b2f8bd 4cea933 0b2f8bd 4cea933 0b2f8bd 4cea933 0b2f8bd 4cea933 0b2f8bd 4cea933 0b2f8bd 4cea933 0b2f8bd 4cea933 0b2f8bd 4cea933 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 | import aiosqlite
import os
import time
import asyncio
from datetime import datetime
from typing import List, Dict, Any
from huggingface_hub import HfApi, hf_hub_download
from config import settings
DB_PATH = os.path.join(os.path.dirname(os.path.abspath(__file__)), settings.db_name)
api = HfApi()
last_sync = 0
sync_lock = asyncio.Lock()
async def sync_from_hub():
global last_sync
if not settings.hf_token:
print("No HF_TOKEN found. Skipping sync.")
return
async with sync_lock:
if time.time() - last_sync < 60:
return
try:
print(f"Downloading {settings.db_name} from Hub...")
def _download():
path = hf_hub_download(
repo_id=settings.repo_id,
filename=settings.db_name,
repo_type="dataset",
token=settings.hf_token,
force_download=True
)
import shutil
shutil.copy(path, DB_PATH)
await asyncio.to_thread(_download)
last_sync = time.time()
print("Sync from Hub complete.")
except Exception as e:
print(f"Sync from Hub failed: {e}")
async def sync_to_hub():
if not settings.hf_token:
return
try:
def _upload():
api.upload_file(
path_or_fileobj=DB_PATH,
path_in_repo=settings.db_name,
repo_id=settings.repo_id,
repo_type="dataset",
token=settings.hf_token
)
await asyncio.to_thread(_upload)
except Exception as e:
print(f"Sync to Hub failed: {e}")
async def init_db() -> None:
await sync_from_hub()
async with aiosqlite.connect(DB_PATH) as db:
await db.execute('''
CREATE TABLE IF NOT EXISTS predictions (
id INTEGER PRIMARY KEY AUTOINCREMENT,
timestamp DATETIME,
heart_rate REAL,
spo2 REAL,
sys_bp REAL,
dia_bp REAL,
temp REAL,
fall_detection TEXT,
prediction_label TEXT,
confidence REAL
)
''')
await db.commit()
async def log_prediction(data: Any, prediction_label: str, confidence: float) -> None:
async with aiosqlite.connect(DB_PATH) as db:
await db.execute('''
INSERT INTO predictions (timestamp, heart_rate, spo2, sys_bp, dia_bp, temp, fall_detection, prediction_label, confidence)
VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)
''', (
datetime.utcnow().strftime("%Y-%m-%d %H:%M:%S"),
data.Heart_Rate,
data.SpO2_Level,
data.Systolic_BP,
data.Diastolic_BP,
data.Body_Temp,
"N/A",
prediction_label,
confidence
))
await db.commit()
async def get_history() -> List[Dict[str, Any]]:
if not os.path.exists(DB_PATH):
return []
async with aiosqlite.connect(DB_PATH) as db:
db.row_factory = aiosqlite.Row
async with db.execute('SELECT * FROM predictions ORDER BY timestamp DESC LIMIT 100') as cursor:
rows = await cursor.fetchall()
return [dict(row) for row in rows]
|