insert_df¶

FactTable.insert_df(dataframe, updatecol=None, chunksize=5000, auto_fit=True)¶

将 DataFrame 的数据插入当前事实表

入库前会对DataFrame的数据作以下处理:

（强制）所有空值变更为 null，确保能正常入库

（强制）以当前时间信息覆盖createdate和createtime列

（非强制）对于 不可为空 的字符串类型数据列，会填充 'null' 字符串（未来可能会修改，不要依赖这个逻辑）

（非强制）对于decimal类型，自动 round 至规定小数位

上述 （非强制） 逻辑，可以通过指定 auto_fit=False 关闭。

参数

dataframe (DataFrame) – 待插入数据
updatecol (Optional[Iterable]) – 更新的列 (用于INSERT INTO ON DUPLICATE)
chunksize (int) – 单次插库的数据行数
auto_fit (bool) – 是否自动进行数据调整

提示

如果单次入库数据过多，导致超出数据库的单条sql语句的上限，可以降低 chuncksize，此方法将把一条较大的sql拆分成多条执行。

返回类型: Union[CustomSqlRespDTO, Dict, List, None]
返回: 执行的操作记录