insert_df_pg

DeepModel.insert_df_pg(object_name, data, chunk_size=500, enable_upsert=False, exclusive_fields=None, update_fields=None)

以事务直连pg执行基于DataFrame字段信息的批量插入数据

参数

• object_name (str) – 被插入数据的对象名，需属于当前应用

• data (DataFrame) – 要插入的数据，只支持single property/link，且single link不可包含link property

• chunk_size (int) – 单次最大行数

• enable_upsert (bool) – 是否组织成insert-on conflict do update 句式

• exclusive_fields (Optional[Iterable[str]]) – enable_upsert为True时的conflict字段，默认为business key

• update_fields (Optional[Iterable[str]]) – enable_upsert为True时的update字段，默认为除business key外所有已提供的字段

返回类型

None