pipeline.src.flows.foreign_fmcs

Functions

extract_foreign_fmcs_contacts(→ pandas.DataFrame)	Extract foreign fmcs contact data from Poseidon.
transform_foreign_fmcs_contacts(→ pandas.DataFrame)	Remove CNSP_SIP_DEPARTMENT_EMAIL where present and aggregate countries' email addresses into arrays.
load_foreign_fmcs(foreign_fmcs)
foreign_fmcs_flow([extract_foreign_fmcs_contacts_task])

Module Contents

pipeline.src.flows.foreign_fmcs.extract_foreign_fmcs_contacts() → pandas.DataFrame

Extract foreign fmcs contact data from Poseidon.

Returns:

foreign fmcs contact data.

Return type:

pd.DataFrame

pipeline.src.flows.foreign_fmcs.transform_foreign_fmcs_contacts(foreign_fmcs_contacts: pandas.DataFrame) → pandas.DataFrame

Remove CNSP_SIP_DEPARTMENT_EMAIL where present and aggregate countries’ email addresses into arrays.

Parameters:

foreign_fmcs_contacts (pd.DataFrame) – Extracted fmc data from Poseidon.

Returns:

Transformed fmc data.

Return type:

pd.DataFrame

pipeline.src.flows.foreign_fmcs.load_foreign_fmcs(foreign_fmcs)

pipeline.src.flows.foreign_fmcs.foreign_fmcs_flow(extract_foreign_fmcs_contacts_task=extract_foreign_fmcs_contacts)