a16400f30ed4_.py 文件源码

def _seed(table_obj, file_path, tx=None):
    with open(file_path, 'r') as f:
        reader = DictReader(f, delimiter=',')
        rows = list(reader)

    if tx is not None:
        rows = [_tx_row(row, tx) for row in rows]

    op.bulk_insert(table_obj, rows)