Files
khqp_trainer/flush.py
2024-03-07 19:47:24 +08:00

61 lines
2.4 KiB
Python

#!/usr/bin/env python3
# -*- coding:utf-8 -*-
from loguru import logger
from bak.evolve_config2 import train_data, val_data
from bak.init_data import BatchDataBase, BatchDataRead
from db_utils import BatchData, session
logger.debug(f"{len(val_data)=}")
for td in val_data:
db_obj = BatchData(**BatchDataBase(**td).dict())
batch_data_db = session.query(BatchData).where(BatchData.img_prefix == td.get("img_prefix")).first()
if batch_data_db:
logger.debug(f"{BatchDataRead.from_orm(batch_data_db)=}")
continue
session.add(db_obj)
# if '2023' in db_obj.ann_file:
# batch_data_db.year = 2023
# census_batch_idx = db_obj.ann_file.index('kh')
# if census_batch_idx:
# census_batch = db_obj.ann_file[census_batch_idx:census_batch_idx + 4].upper()
# census_batches.append(census_batch)
# batch_data_db.census_batch = census_batch
#
# batch_data_db.precision = 'S3'
# batch_data_db.is_train = True
# batch_data_db.is_validation = False
#
# id_code_idx = census_batch_idx + 5
# if batch_data_db.id_code is None:
# if batch_data_db.id > 29:
# code_start = db_obj.ann_file[id_code_idx + 21:]
# code_end = code_start.index('_')
# id_code = db_obj.ann_file[id_code_idx + 21:][:code_end]
# logger.debug(f"{id_code}, {db_obj.ann_file[id_code_idx + 21:]}, {db_obj.ann_file[id_code_idx:]}, {batch_data_db.id=}")
# batch_data_db.id_code = id_code
# if batch_data_db.id > 25 and batch_data_db.id <= 29:
# code_start = db_obj.ann_file[id_code_idx + 18:]
# code_end = code_start.index('_')
# id_code = db_obj.ann_file[id_code_idx + 18:][:code_end]
# logger.debug(f"{db_obj.ann_file[id_code_idx + 18:]}, {db_obj.ann_file[id_code_idx:]}, {id_code}, {batch_data_db.id=}")
# batch_data_db.id_code = id_code
# if 2 < batch_data_db.id <= 25:
# id_code = db_obj.ann_file[id_code_idx:id_code_idx + 3]
# logger.debug(f"{id_code=}")
# batch_data_db.id_code = id_code
# if 25 < batch_data_db.id <= 25:
# id_code = db_obj.ann_file[id_code_idx:id_code_idx + 3]
# logger.debug(f"{id_code=}")
# batch_data_db.id_code = id_code
# if not batch_data_db:
# logger.debug(f"insert {db_obj.ann_file=}")
# session.add(db_obj)
session.commit()