main.py 文件源码

def insert_or_report(execute_fn, table, rows):
    try:
        execute_fn(insert(table).values(rows))
    except Exception as exc:
        print(rows)
        print(exc)
        return
    LOGGER.info(
        '%s Inserted %s rows',
        datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S'),
        len(rows)
    )