Job Details
As part of HR DQ project, we have developed the below Talend jobs which gets the data from SuccessFactor tables and ingest data into the respective STG/ODS tables. We are following the DataOcean standard jobs.
| Talend Job name | SuccessFactor Table name | Talend project | GCP Project | STG Table | ODS table |
| F010_SAP_SF_EmpJob_SAP_SF_to_ODS | EmpJob | DATA_OCEAN_DOMAIN_HR | prj-data-dm-hr-prod | STG_SFC_0000_0000_F001_F_D_EmpJob | ODS_SFC_0000_F001_F_D_EmpJob |
| F009_SAP_SF_EmpEmployment_SAP_SF_to_ODS | EmpEmployment | DATA_OCEAN_DOMAIN_HR | prj-data-dm-hr-prod | STG_SFC_0000_0000_F001_F_D_EmpEmployment | ODS_SFC_0000_F001_F_D_EmpEmployment |
| F005_SAP_SF_EmpEmploymentTermination_SAP_SF_to_ODS | EmpEmploymentTermination | DATA_OCEAN_DOMAIN_HR | prj-data-dm-hr-prod | STG_SFC_0000_0000_F001_F_D_EmpEmploymentTermination | ODS_SFC_0000_F001_F_D_EmpEmploymentTermination |
| F006_SAP_SF_EmpPayCompRecurring_SAP_SF_to_ODS | EmpPayCompRecurring | DATA_OCEAN_DOMAIN_HR | prj-data-dm-hr-prod | STG_SFC_0000_0000_F001_F_D_EmpPayCompRecurring | ODS_SFC_0000_F001_F_D_EmpPayCompRecurring |
| F007_SAP_SF_EmpCompensation_SAP_SF_to_ODS | EmpCompensation | DATA_OCEAN_DOMAIN_HR | prj-data-dm-hr-prod | STG_SFC_0000_0000_F001_F_W_EmpCompensation | ODS_SFC_0000_F001_F_W_EmpCompensation |
| F008_SAP_SF_FOPayComponent_SAP_SF_to_ODS | FOPayComponent | DATA_OCEAN_DOMAIN_HR | prj-data-dm-hr-prod | STG_SFC_0000_0000_F001_F_D_FOPayComponent | ODS_SFC_0000_F001_F_D_FOPayComponent |
| F004_SAP_SF_EmpJobRelationships_SAP_SF_to_ODS | EmpJobRelationships | DATA_OCEAN_DOMAIN_HR | prj-data-dm-hr-prod | STG_SFC_0000_0000_F001_F_D_EmpJobRelationships | ODS_SFC_0000_F001_F_D_EmpJobRelationships |
| F001_SAP_SF_PerEmail_SAP_SF_to_ODS | PerEmail | DATA_OCEAN_DOMAIN_HR | prj-data-dm-hr-prod | STG_SFC_0000_0000_F001_F_D_PerEmail | ODS_SFC_0000_F001_F_D_PerEmail |
| F002_SAP_SF_PerPersonal_SAP_SF_to_ODS | PerPerson | DATA_OCEAN_DOMAIN_HR | prj-data-dm-hr-prod | STG_SFC_0000_0000_F001_F_D_PerPerson | ODS_SFC_0000_F001_F_D_PerPerson |
| F003_SAP_SF_PerPerson_SAP_SF_to_ODS | PerPersonal | DATA_OCEAN_DOMAIN_HR | prj-data-dm-hr-prod | STG_SFC_0000_0000_F001_F_D_PerPersonal | ODS_SFC_0000_F001_F_D_PerPersonal |
| F011_SAP_SF_FOEventReason_csv_to_GCS | FOEventReason | DATA_OCEAN_DOMAIN_HR | prj-data-dm-hr-prod | STG_SFC_0000_0000_F001_F_W_FOEventReason | ODS_SFC_0000_F001_F_W_FOEventReason |
| F012_SAP_SF_UserAccount_csv_to_GCS | UserAccount | DATA_OCEAN_DOMAIN_HR | prj-data-dm-hr-prod | STG_SFC_0000_0000_F001_F_W_UserAccount | ODS_SFC_0000_F001_F_W_UserAccount |
| F014_SAP_FOLocationGroup_SAP_SF_to_ODS | FOLocationGroup | DATA_OCEAN_DOMAIN_HR | prj-data-dm-hr-prod | STG_SFC_0000_0000_F001_F_W_FOLocationGroup | ODS_SFC_0000_F001_F_W_FOLocationGroup |
| F015_SAP_FOCompany_SAP_SF_to_ODS | FOCompany | DATA_OCEAN_DOMAIN_HR | prj-data-dm-hr-prod | STG_SFC_0000_0000_F001_F_W_FOCompany | ODS_SFC_0000_F001_F_W_FOCompany |
| F016_SAP_FOCostCenter_SAP_SF_to_ODS | FOCostCenter | DATA_OCEAN_DOMAIN_HR | prj-data-dm-hr-prod | STG_SFC_0000_0000_F001_F_W_FOCostCenter | ODS_SFC_0000_F001_F_W_FOCostCenter |
| F017_SAP_FOBusinessUnit_SAP_SF_to_ODS | FOBusinessUnit | DATA_OCEAN_DOMAIN_HR | prj-data-dm-hr-prod | STG_SFC_0000_0000_F001_F_W_FOBusinessUnit | ODS_SFC_0000_F001_F_W_FOBusinessUnit |
| F018_SAP_PickListValueV2_SAP_SF_to_ODS | PickListValueV2 | DATA_OCEAN_DOMAIN_HR | prj-data-dm-hr-prod | STG_SFC_0000_0000_F001_F_W_PickListValueV2 | ODS_SFC_0000_F001_F_W_PickListValueV2 |
| F019_SAP_Position_SAP_SF_to_ODS | Position | DATA_OCEAN_DOMAIN_HR | prj-data-dm-hr-prod | STG_SFC_0000_0000_F001_F_W_Position | ODS_SFC_0000_F001_F_W_Position |
| F020_SAP_EmpWorkPermit_SAP_SF_to_ODS | EmpWorkPermit | DATA_OCEAN_DOMAIN_HR | prj-data-dm-hr-prod | STG_SFC_0000_0000_F001_F_W_EmpWorkPermit | ODS_SFC_0000_F001_F_W_EmpWorkPermit |
| F021_SAP_FOLocation_SAP_SF_to_ODS | FOLocation | DATA_OCEAN_DOMAIN_HR | prj-data-dm-hr-prod | STG_SFC_0000_0000_F001_F_W_FOLocation | ODS_SFC_0000_F001_F_W_FOLocation |
| F012_SAP_User_SAP_SF_to_ODS | User | DATA_OCEAN_DOMAIN_HR | prj-data-dm-hr-prod | STG_SFC_0000_0000_F001_F_W_User | ODS_SFC_0000_F001_F_W_User |
Talend flow explanation
Data Validation/Troubleshoot queries
Data Validation:
<Provide the SQL queries to validate the data or the record count in the BQ target tables>
Logging:
<Details about the log tables in Big query>
Troubleshoot steps:
<Provide the steps to debug the ETL flow in case of failure. For example, if an ETL job fails, how should we trigger it? Can we directly rerun the job, or are there steps to delete the data from the previous execution before rerunning the job? or any change should be made in the context table for date executions>