Loaders

SolerPerson

SolerPersonLoader

Class for loading data for Soler pipeline.

clean_person()

Helper function for updating Soler.PersonClean table.

create_personclean()

Helper function for creating Core.PersonClean table.

create_personresolved()

Helper function for creating Core.PersonResolved table.

drop_personclean()

Helper function for dropping Core.PersonClean table.

drop_personresolved()

Helper function for dropping Core.PersonResolved table.

fast_resolve_by_program(program)

Function to quickly resolve bulk set of records to themselves by program Used to resolve programs that do not track person information (i.e. Germany, China, etc.)

Keyword args: program (str): program to bulk resolve

insert_missing_records()

Bulk insert records resolved only to themselves

load_to_core()

Function to join PersonIds to PersonUuids and insert into Core.PersonResolved

load_to_solerresolved(program_temp, update=False, record_id=0)

Helper function for loading Soler.temp_resolve_* temp tables to Core.PersonResolved.

resolve_record(record_id)

Function that resolves individual record to itself

SolerProgram

SolerProgramLoader

Class for loading data for Soler pipeline.

create_programresolved()

Helper function for dropping Core.PersonResolved table.

drop_programresolved()

Helper function for creating Core.ProgramResolved table.

insert_missing_records()

Bulk insert records resolved only to themselves

load_programs_to_core(df)

Function for writing resolved programs df to Core.ProgramResolved

Keyword args: df (pandas.DataFrame) : dataframe containing resolved programs

load_soi_programs()

Function to load so_programs.csv to Soler.SOIPrograms

program_fast_resolved()

Function to conduct fast resolve on Core.Organization in sql

resolve_record(record_id)

Function that resolves individual record to itself