agent0.chainsync.df_to_db

Helper function to add a dataframe to a database.

Attributes

MAX_BATCH_SIZE

Functions

df_to_db(insert_df, schema_obj, session)

Helper function to add a dataframe to a database.

Module Contents

agent0.chainsync.df_to_db.MAX_BATCH_SIZE = 10000
agent0.chainsync.df_to_db.df_to_db(insert_df: pandas.DataFrame, schema_obj: Type[agent0.chainsync.db.base.DBBase], session: sqlalchemy.orm.Session)

Helper function to add a dataframe to a database.

Parameters:

  • insert_df (pd.DataFrame) – The dataframe to insert.

  • schema_obj (Type[Base]) – The schema object to use.

  • session (Session) – The initialized session object.