informatica.infacore.datapipeline.datapipeline.DataPipeline.execute

DataPipeline.execute(src_dfs=None, tgt_dfs=None, parameters=None)

Executes the data pipeline with the specified source and target native DataFrames and data pipeline parameters.

Parameters:

• src_dfs (dict) – Source native DataFrame.

• tgt_dfs (dict) – Target DataFrame. Skip for using staging.

• parameters (dict) – Data pipeline parameters in “key, value” pairs.

Returns:

Native DataFrame object.

Return type:

Object

Example

>>> import informatica.infacore as ic
>>> scd_dp = ic.get_data_pipeline("scd type 2")
>>> params = {
        "i_param_1": "",
        "i_param_2": ""
    }
>>> orcl_cnx = scd_dp.execute(src_dfs, parameters=params)