Function chunked_rows

scripts/migrate_sqlite_to_postgres.py:68–72

(rows: Sequence[dict], chunk_size: int)

def chunked_rows(rows: Sequence[dict], chunk_size: int) -> Iterator[list[dict]]:
    if chunk_size <= 0:
        raise MigrationError("chunk_size 必须大于 0")
    for index in range(0, len(rows), chunk_size):
        yield list(rows[index:index + chunk_size])


def reflect_metadata(engine: Engine) -> MetaData: