diff --git a/Job asier.kjb b/Job asier.kjb new file mode 100644 index 0000000..378e006 --- /dev/null +++ b/Job asier.kjb @@ -0,0 +1,546 @@ + + + python_script + + + + 0 + / + - + 2021/12/16 09:34:06.807 + - + 2021/12/16 09:34:06.807 + + + data_location + ${source_folder} + Where te tested data is located + + + endpoint_name + ${endpoint} + Which endpoint name you wrote on properties.config + + + result_location + ${results_folder} + where the results are located + + + + + + + + + + + + + ID_JOB + Y + ID_JOB + + + CHANNEL_ID + Y + CHANNEL_ID + + + JOBNAME + Y + JOBNAME + + + STATUS + Y + STATUS + + + LINES_READ + Y + LINES_READ + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + LINES_UPDATED + Y + LINES_UPDATED + + + LINES_INPUT + Y + LINES_INPUT + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + LINES_REJECTED + Y + LINES_REJECTED + + + ERRORS + Y + ERRORS + + + STARTDATE + Y + STARTDATE + + + ENDDATE + Y + ENDDATE + + + LOGDATE + Y + LOGDATE + + + DEPDATE + Y + DEPDATE + + + REPLAYDATE + Y + REPLAYDATE + + + LOG_FIELD + Y + LOG_FIELD + + + EXECUTING_SERVER + N + EXECUTING_SERVER + + + EXECUTING_USER + N + EXECUTING_USER + + + START_JOB_ENTRY + N + START_JOB_ENTRY + + + CLIENT + N + CLIENT + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + JOBNAME + Y + TRANSNAME + + + JOBENTRYNAME + Y + STEPNAME + + + LINES_READ + Y + LINES_READ + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + LINES_UPDATED + Y + LINES_UPDATED + + + LINES_INPUT + Y + LINES_INPUT + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + LINES_REJECTED + Y + LINES_REJECTED + + + ERRORS + Y + ERRORS + + + RESULT + Y + RESULT + + + NR_RESULT_ROWS + Y + NR_RESULT_ROWS + + + NR_RESULT_FILES + Y + NR_RESULT_FILES + + + LOG_FIELD + N + LOG_FIELD + + + COPY_NR + N + COPY_NR + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + LOGGING_OBJECT_TYPE + Y + LOGGING_OBJECT_TYPE + + + OBJECT_NAME + Y + OBJECT_NAME + + + OBJECT_COPY + Y + OBJECT_COPY + + + REPOSITORY_DIRECTORY + Y + REPOSITORY_DIRECTORY + + + FILENAME + Y + FILENAME + + + OBJECT_ID + Y + OBJECT_ID + + + OBJECT_REVISION + Y + OBJECT_REVISION + + + PARENT_CHANNEL_ID + Y + PARENT_CHANNEL_ID + + + ROOT_CHANNEL_ID + Y + ROOT_CHANNEL_ID + + + N + + + + Start + + SPECIAL + + Y + N + N + 0 + 0 + 60 + 12 + 0 + 1 + 1 + N + Y + 0 + 112 + 80 + + + + filter_3.6 + + TRANS + + filename + + ${Internal.Entry.Current.Directory}/separate_failed/filter_3.6.ktr + + N + N + N + N + N + N + + + N + N + Basic + N + + N + Y + N + N + N + Pentaho local + N + + Y + + in_csv + ${result_location}/${endpoint_name}.csv + + + + out_csv + ${result_location}/testout_${endpoint_name}.csv + + + + N + Y + 0 + 368 + 80 + + + + extract_files_to_folder_1 + + SHELL + + + ${Internal.Entry.Current.Directory}/separate_failed/ + N + N + N + + N + + N + N + Y + + Basic + N + Y + 0 + 480 + 192 + + + + bulk_validation_1 + + JOB + + filename + + ${Internal.Entry.Current.Directory}/pdi/validation.kjb + + + N + N + N + N + + + N + N + Nothing + + Y + N + N + N + N + Pentaho local + + Y + + N + N + Y + 0 + 256 + 80 + + + + File exists + + FILE_EXISTS + + ${result_location}/testout_${endpoint_name}.csv + N + Y + 0 + 480 + 80 + + + + Count_total_fails + + TRANS + + filename + + ${Internal.Entry.Current.Directory}/summarize_errors.ktr + + N + N + N + N + N + N + + + N + N + Basic + N + + N + Y + N + N + N + Pentaho local + N + + Y + + results_folder + ${result_location} + + + + N + Y + 0 + 672 + 144 + + + + + + Start + bulk_validation_1 + 0 + 0 + Y + Y + Y + + + bulk_validation_1 + filter_3.6 + 0 + 0 + Y + Y + Y + + + filter_3.6 + File exists + 0 + 0 + Y + Y + N + + + File exists + extract_files_to_folder_1 + 0 + 0 + Y + Y + N + + + File exists + Count_total_fails + 0 + 0 + Y + N + N + + + + + + diff --git a/README.md b/README.md index 0aa9f9a..76b45ef 100644 --- a/README.md +++ b/README.md @@ -1,23 +1,26 @@ ## Bulk processing tool for the INSPIRE Reference Validator -This software tool allows for validation of large numbers of metadata records using the API of the [INSPIRE Reference Validator](https://inspire.ec.europa.eu/validator/about/). It was developed to support INSPIRE Monitoring & Reporting activities. The tool was built with [Pentaho Data Integration Community Edition](https://community.hitachivantara.com/s/article/data-integration-kettle) platform which is required to use it. +This software tool allows for validation of large numbers of metadata records using the API of the [INSPIRE Reference Validator](https://inspire.ec.europa.eu/validator/about/). It was developed to support INSPIRE Monitoring & Reporting activities. The tool was built with [Pentaho Data Integration] platform which is required to use it. ### Prerequisites -- One or more instances of **INSPIRE Reference Validator** [latest release](https://github.com/inspire-eu-validation/community/releases/latest). -- **Pentaho Data Integration** (PDI) **Community Edition** (CE), suggested PDI CE version is [9.0](https://sourceforge.net/projects/pentaho/files/Pentaho%209.0/client-tools/pdi-ce-9.0.0.0-423.zip/download) or 8.2, (8.3 suffers from JSON Input step performance deterioration and is not recommended). In case of slow download click "Problems downloading?" and try an alternative download mirror. -- **Apache HttpClient** components [4.5.12](https://downloads.apache.org/httpcomponents/httpclient/binary/httpcomponents-client-4.5.12-bin.zip). -- Source metadata compiled according to the **INSPIRE Technical Guidelines** (TG) version **2.0** and available as XML files with single metadata record per file. +- One or more instances of **INSPIRE Reference Validator** [latest release](https://github.com/inspire-eu-validation/community/releases/latest). +- JDK Version 11 (or newer) (https://jdk.java.net/archive/) +- Pentaho Data Integration Community (PDI) v.10.2.0.0-222 (https://pentaho.com/pentaho-developer-edition/ you have to register yourself in order to download it) +- Apache HttpClient v.4.5.14 (https://hc.apache.org/downloads.cgi binary tar.gz) +- Python 3 + +### Installation +- Set JAVA_HOME variable in order to point to the jdk dowloaded before +- Unzip PDI folder +- Copy the inspire-validator.jar in the lib folder of the PDI. +- Unzip HttpClient file and copy from the lib folder the httpmime-4.5.14.jar in the lib folder of the PDI. +- Launch from the Terminal the spoon.sh (Linux env) or spoon.bat (Windows env) script in order to open the Tool (don't worry if you obtain some warning regarding a library to install: it is not strictly required). -### Installation -- Unzip PDI, -- copy all *.jar* files from Apache HttpClient to your PDI *lib* folder, -- copy [*inspire-validator.jar*](inspire-validator.jar) to your PDI *lib* folder, -- in [*validation.bat*](validation.bat) insert the path to your PDI *data-integration* folder. ### Configuration In [*pdi/config.properties*](pdi/config.properties) update the following items: - `endpoint` - endpoint id, used to create file- and folder- names [use only characters valid for a filename], -- `source_folder` - folder where source metadata are located (including subfolders) [use forward slashes "/" in the path], -- `results_folder` - folder where results will be written [use forward slashes "/" in the path], +- `source_folder` - folder where source metadata are located (including subfolders) [use forward slashes "/" in the path, also in Windows env], +- `results_folder` - folder where results will be written [use forward slashes "/" in the path, also in Windows env], - `source_suffix` - source metadata files suffix, used to filter the files to validate, - `validator_nodes` - number of validator instances to use, `validator_url_X` needs to be provided for each instance, - `validator_url_X` - URLs for each validator instance, up to "/v2/" [*http://.../v2/*], @@ -25,29 +28,51 @@ In [*pdi/config.properties*](pdi/config.properties) update the following items: - `queue_max_size` - maximum number of test runs that can be run in parallel on each validator instance. ### Usage -Run [*validation.bat*](validation.bat) script, it will perform preprocessing, validation and results generation as described below: -1. Preprocessing: - - read all files with the given *\* located in *\* (including subfolders) that were not validated before; - - identify records with missing or unknown type; - - identify duplicate records using MD5 hash values; - - create *\.md.json* metadata summary (after completed preprocessing of all records). -2. Validation: - - validate each record using *\* number of instances of the INSPIRE Reference Validator with *\* URLs; 3 different conformance classes (as specified in the configuration file) are used for the validation of: - - data sets and data set series, - - network services, - - invocable spatial data services (identified by the value *other* for *serviceType* XML element); - - save validation reports for each record in *\*/*\* folder: - - the subfolder structure of *\* is preserved, - - filenames correspond to those of source metadata with *\* removed, - - each report is saved in two versions: *.html* and *.json*; - - add results for each record to CSV results *\.csv*, detailed [below](#results-csv-columns). -3. Results: - - after completed validation of all source metadata the following result files are generated: *\.json*, *\.services.zip*, *\.dataset.zip* and *validation.csv*, detailed [below](#result-files); - - the results can be used to calculate the conformity indicators as detailed [below](#conformity-indicators). - -In case the validation does not complete for all source metadata (due to errors, user interruption, etc.), when the transformation is run for the same endpoint again, it will continue processing source metadata that were not processed before, hence are not included in CSV results. To re-validate an endpoint that was validated before, the CSV results file needs to be renamed or moved out of the results folder. - -Alternatively, the procedure can be run from the PDI user interface (Spoon) which provides more control and feedback, and allows for modifications. For this purpose run *Spoon.bat*, open and run [*pdi/validation.kjb*](pdi/validation.kjb) job. +- On your local machine create a new dedicated folder, called for example 'BULK_VALIDATOR' and two sub-folder 'INPUT' and 'OUTPUT'. + +- In the INPUT folder put the folder and the files of the countries used for the validation process. + +- Open from the scripts folder, the file 'Job asier.kjb' inside the folder InspireTeam-scripts and modify the variables that contain link to other files with your local path (3 occurrences) (In order to find them, try so search '/home/user/Documents'). + +- From spoon, open the process 'Job asier.ktr' from the InspireTeam-scripts folder (no input parameters have to be inserted because the process reads them from the config.properties). + +- At the end of the process, check if inside the OUTPUT folder, a new folder with the country code as name has been created. It should contain some files. + +- If in the OUTPUT folder a new folder named 'resteting-endpoint' and 'testout_endpoint' have been created, some errors 3.6 are present. + +- (If this folder is not present, go to step (*)) + +- Launch again the process 'Job asier.ktr' modifying the config.properties file putting as source_folder the restesting folder and as results_folder a folder named with the endpoint in the retesting folder. + +- Go to 'monitoring-bulk-validation-tool/saparated_failed', open a terminal and launch this command: + + python3 intersect.py /home//Documents/BULK_VALIDATION/OUTPUT//// /home//Documents/BULK_VALIDATION/OUTPUT///retesting-/ /home//Documents/BULK_VALIDATION/OUTPUT///testout_.csv /home//Documents/BULK_VALIDATION/OUTPUT///.csv + + where and will be substituted by the country code and the endpoint of the country. + + In this command, there are four variables (starting from '/home') that are: + 1) report total location (folder where html and json file created are) + 2) report error location (new retesting folder) + 3) file errors (new testout file created) + 4) file total (csv created after the first process) + + Repeat these last two steps for 3 times in order to check multiples time metadata that give 3.6 errors. + +- (*) Open with spoon the process 'summarize_error.ktr' from the InspireTeam-scripts folder. In the input parameters, configure: + [*path_folder*] with path of the csv called with the endpoint generated from the process before. + [*results_folder*] with the path that contains all the files. + + For example: + results_folder=/home//Documents/BULK_VALIDATION/OUTPUT///.csv + path_folder=/home//Documents/BULK_VALIDATION/OUTPUT/// + +- At the end of the process, verify that in the results_folder has been created the file 'summarize_error.xlsx'. + +- Open the process 'filter_failed_csv_2.ktr' from the InspireTeam-scripts folder. In the input parameters, configure: + [*in_csv*] with the the same value used for the variable 'results_folder' before. + +- At the end of the process, in the OUTPUT folder, the file -error.csv will contain the errors. It this file is not present, no errors have been detected. + #### Result files All result files are saved in *\*: @@ -81,32 +106,5 @@ MDi1.2 = service_metadata_passed / DSi1.2 ### Support If you experience any issue in the setup and/or use of the software, please open an issue in the [INSPIRE Validator helpdesk](https://github.com/inspire-eu-validation/community/issues/new/choose). -### External document references - -| Abbreviation | Document name | -| ------------ | ----------------------------------- | -| INSPIRE | [Directive 2007/2/EC of the European Parliament and of the Council of 14 March 2007 establishing an Infrastructure for Spatial Information in the European Community (INSPIRE)](http://eur-lex.europa.eu/legal-content/EN/TXT/PDF/?uri=CELEX:32007L0002&from=EN) | -| ID M&R | [COMMISSION IMPLEMENTING DECISION (EU) 2019/1372 of 19 August 2019 implementing Directive 2007/2/EC of the European Parliament and of the Council as regards monitoring and reporting](https://eur-lex.europa.eu/legal-content/EN/TXT/PDF/?uri=CELEX:32019D1372&from=EN) | - -### Acknowledgments -This software tool was developed with contributions by: -- [Lukasz Ziemba](https://github.com/ukiz) -- [Davide Artasensi](https://github.com/dartasensi) -- [Marco Minghini](https://github.com/MarcoMinghini) -- [Fabio Vinci](https://github.com/fabiovin) - -This work was supported by the [Interoperability solutions for public administrations, businesses and citizens programme](http://ec.europa.eu/isa2) through Action 2016.10: European Location Interoperability Solutions for e-Government (ELISE). - -### Licence -Copyright 2020 EUROPEAN UNION -Licensed under the EUPL, Version 1.2 or - as soon as they will be approved by the European Commission - subsequent versions of the EUPL (the "Licence"). -You may not use this work except in compliance with the Licence. -You may obtain a copy of the Licence at: - -https://ec.europa.eu/isa2/solutions/european-union-public-licence-eupl_en - -Unless required by applicable law or agreed to in writing, software distributed under the Licence is distributed on an "AS IS" basis, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -See the Licence for the specific language governing permissions and limitations under the Licence. -Date: 2020/06/08 -Authors: European Commission, Joint Research Centre - jrc-inspire-support@ec.europa.eu +Date: 2024/12/11 diff --git a/filter_failed_csv_2.ktr b/filter_failed_csv_2.ktr new file mode 100644 index 0000000..d41a905 --- /dev/null +++ b/filter_failed_csv_2.ktr @@ -0,0 +1,751 @@ + + + + filter_failed_csv + + + + Normal + 0 + / + + + in_csv + + input csv path + + + out_csv + ${in_csv}-error + output csv path + + + + + + +
+ + + + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + TRANSNAME + Y + TRANSNAME + + + STATUS + Y + STATUS + + + LINES_READ + Y + LINES_READ + + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + + LINES_UPDATED + Y + LINES_UPDATED + + + + LINES_INPUT + Y + LINES_INPUT + + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + + LINES_REJECTED + Y + LINES_REJECTED + + + + ERRORS + Y + ERRORS + + + STARTDATE + Y + STARTDATE + + + ENDDATE + Y + ENDDATE + + + LOGDATE + Y + LOGDATE + + + DEPDATE + Y + DEPDATE + + + REPLAYDATE + Y + REPLAYDATE + + + LOG_FIELD + Y + LOG_FIELD + + + EXECUTING_SERVER + N + EXECUTING_SERVER + + + EXECUTING_USER + N + EXECUTING_USER + + + CLIENT + N + CLIENT + + + + + +
+ + + + ID_BATCH + Y + ID_BATCH + + + SEQ_NR + Y + SEQ_NR + + + LOGDATE + Y + LOGDATE + + + TRANSNAME + Y + TRANSNAME + + + STEPNAME + Y + STEPNAME + + + STEP_COPY + Y + STEP_COPY + + + LINES_READ + Y + LINES_READ + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + LINES_UPDATED + Y + LINES_UPDATED + + + LINES_INPUT + Y + LINES_INPUT + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + LINES_REJECTED + Y + LINES_REJECTED + + + ERRORS + Y + ERRORS + + + INPUT_BUFFER_ROWS + Y + INPUT_BUFFER_ROWS + + + OUTPUT_BUFFER_ROWS + Y + OUTPUT_BUFFER_ROWS + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + LOGGING_OBJECT_TYPE + Y + LOGGING_OBJECT_TYPE + + + OBJECT_NAME + Y + OBJECT_NAME + + + OBJECT_COPY + Y + OBJECT_COPY + + + REPOSITORY_DIRECTORY + Y + REPOSITORY_DIRECTORY + + + FILENAME + Y + FILENAME + + + OBJECT_ID + Y + OBJECT_ID + + + OBJECT_REVISION + Y + OBJECT_REVISION + + + PARENT_CHANNEL_ID + Y + PARENT_CHANNEL_ID + + + ROOT_CHANNEL_ID + Y + ROOT_CHANNEL_ID + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + TRANSNAME + Y + TRANSNAME + + + STEPNAME + Y + STEPNAME + + + STEP_COPY + Y + STEP_COPY + + + LINES_READ + Y + LINES_READ + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + LINES_UPDATED + Y + LINES_UPDATED + + + LINES_INPUT + Y + LINES_INPUT + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + LINES_REJECTED + Y + LINES_REJECTED + + + ERRORS + Y + ERRORS + + + LOG_FIELD + N + LOG_FIELD + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + METRICS_DATE + Y + METRICS_DATE + + + METRICS_CODE + Y + METRICS_CODE + + + METRICS_DESCRIPTION + Y + METRICS_DESCRIPTION + + + METRICS_SUBJECT + Y + METRICS_SUBJECT + + + METRICS_TYPE + Y + METRICS_TYPE + + + METRICS_VALUE + Y + METRICS_VALUE + + + + + +
+ + 0.0 + 0.0 + + 10000 + 50 + 50 + N + Y + 50000 + Y + + N + 1000 + 100 + + + + + + + + + - + 2021/01/20 11:06:54.110 + - + 2021/01/20 11:06:54.110 + H4sIAAAAAAAAAAMAAAAAAAAAAAA= + N + + + + + + read CSV + Filter rows + Y + + + Filter rows + write result + Y + + + + Filter rows + FilterRows + + Y + + 1 + + none + + + write result + + + + N + + + N + result + = + + + constant + String + FAILED + -1 + -1 + N + + + + + + + + + + + + + + + + 608 + 80 + Y + + + + read CSV + CsvInput + + Y + + 1 + + none + + + ${in_csv} + in + + N + ; + " +
Y
+ 50000 + N + N + N + N + + + + + file_id + String + + $ + . + , + 23 + -1 + none + + + md_id + String + + $ + . + , + 36 + -1 + none + + + type + String + + $ + . + , + 7 + -1 + none + + + result + String + + $ + . + , + 6 + -1 + none + + + MD5 + String + + + + + -1 + -1 + none + + + error_count + String + + + + + -1 + -1 + none + + + errors + String + + + + + -1 + -1 + none + + + + + + + + + + + + 480 + 80 + Y + + + + write result + TextFileOutput + + Y + + 1 + + none + + + ; + " + N + N +
Y
+
N
+ DOS + None + windows-1252 + + N + out_csv + N + + ${out_csv} + N + Y + + N + N + N + N + N + N + + N + N + N + 0 + + + + file_id + String + + + + + + none + -1 + -1 + + + md_id + String + + + + + + none + -1 + -1 + + + type + String + + + + + + none + -1 + -1 + + + error_count + Integer + + + + + + none + -1 + -1 + + + errors + String + + + + + + none + -1 + -1 + + + + + + + + + + + + 736 + 80 + Y + + + + + + + N + + diff --git a/separate_failed/errors_sub.ktr b/separate_failed/errors_sub.ktr new file mode 100644 index 0000000..b0f47c4 --- /dev/null +++ b/separate_failed/errors_sub.ktr @@ -0,0 +1,696 @@ + + + + errors_sub + + + + Normal + / + + + + + + +
+ + + + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + TRANSNAME + Y + TRANSNAME + + + STATUS + Y + STATUS + + + LINES_READ + Y + LINES_READ + + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + + LINES_UPDATED + Y + LINES_UPDATED + + + + LINES_INPUT + Y + LINES_INPUT + + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + + LINES_REJECTED + Y + LINES_REJECTED + + + + ERRORS + Y + ERRORS + + + STARTDATE + Y + STARTDATE + + + ENDDATE + Y + ENDDATE + + + LOGDATE + Y + LOGDATE + + + DEPDATE + Y + DEPDATE + + + REPLAYDATE + Y + REPLAYDATE + + + LOG_FIELD + Y + LOG_FIELD + + + EXECUTING_SERVER + N + EXECUTING_SERVER + + + EXECUTING_USER + N + EXECUTING_USER + + + CLIENT + N + CLIENT + + + + + +
+ + + + ID_BATCH + Y + ID_BATCH + + + SEQ_NR + Y + SEQ_NR + + + LOGDATE + Y + LOGDATE + + + TRANSNAME + Y + TRANSNAME + + + STEPNAME + Y + STEPNAME + + + STEP_COPY + Y + STEP_COPY + + + LINES_READ + Y + LINES_READ + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + LINES_UPDATED + Y + LINES_UPDATED + + + LINES_INPUT + Y + LINES_INPUT + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + LINES_REJECTED + Y + LINES_REJECTED + + + ERRORS + Y + ERRORS + + + INPUT_BUFFER_ROWS + Y + INPUT_BUFFER_ROWS + + + OUTPUT_BUFFER_ROWS + Y + OUTPUT_BUFFER_ROWS + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + LOGGING_OBJECT_TYPE + Y + LOGGING_OBJECT_TYPE + + + OBJECT_NAME + Y + OBJECT_NAME + + + OBJECT_COPY + Y + OBJECT_COPY + + + REPOSITORY_DIRECTORY + Y + REPOSITORY_DIRECTORY + + + FILENAME + Y + FILENAME + + + OBJECT_ID + Y + OBJECT_ID + + + OBJECT_REVISION + Y + OBJECT_REVISION + + + PARENT_CHANNEL_ID + Y + PARENT_CHANNEL_ID + + + ROOT_CHANNEL_ID + Y + ROOT_CHANNEL_ID + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + TRANSNAME + Y + TRANSNAME + + + STEPNAME + Y + STEPNAME + + + STEP_COPY + Y + STEP_COPY + + + LINES_READ + Y + LINES_READ + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + LINES_UPDATED + Y + LINES_UPDATED + + + LINES_INPUT + Y + LINES_INPUT + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + LINES_REJECTED + Y + LINES_REJECTED + + + ERRORS + Y + ERRORS + + + LOG_FIELD + N + LOG_FIELD + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + METRICS_DATE + Y + METRICS_DATE + + + METRICS_CODE + Y + METRICS_CODE + + + METRICS_DESCRIPTION + Y + METRICS_DESCRIPTION + + + METRICS_SUBJECT + Y + METRICS_SUBJECT + + + METRICS_TYPE + Y + METRICS_TYPE + + + METRICS_VALUE + Y + METRICS_VALUE + + + + + +
+ + 0.0 + 0.0 + + 10000 + 50 + 50 + N + Y + 50000 + Y + + N + 1000 + 100 + + + + + + + + + - + 2020/04/13 18:26:39.470 + - + 2020/04/13 18:26:39.470 + + N + + + + + + Split field to rows 2 + Sort rows 2 + Y + + + Select values 2 + Split field to rows 2 + Y + + + Select values 2 + Add constants 2 + Y + + + Add constants 2 + Sort rows 2 + Y + + + Mapping input specification + Select values 2 + Y + + + Sort rows 2 + Mapping output specification + Y + + + + Split field to rows 2 + SplitFieldToRows3 + + Y + + 1 + + none + + + errors + + error + N + + Y + N + + + + + + + + + + 304 + 64 + Y + + + + Sort rows 2 + SortRows + + Y + + 1 + + none + + + %%java.io.tmpdir%% + out + 1000000 + + N + + N + + + endpoint + Y + N + N + 0 + N + + + error + Y + N + N + 0 + N + + + + + + + + + + + + 432 + 64 + Y + + + + Select values 2 + SelectValues + + N + + 1 + + none + + + + + endpoint + + + errors + + N + + + + + + + + + + + 160 + 64 + Y + + + + Add constants 2 + Constant + + Y + + 1 + + none + + + + + error + String + + + + + total + -1 + -1 + N + + + + + + + + + + + + 304 + 96 + Y + + + + Mapping input specification + MappingInput + + Y + + 1 + + none + + + + + endpoint + String + -1 + -1 + + + errors + String + -1 + -1 + + N + + + + + + + + + + + 48 + 64 + Y + + + + Mapping output specification + MappingOutput + + Y + + 1 + + none + + + + + + + + + + + + 560 + 64 + Y + + + + + + + N + + diff --git a/separate_failed/filter_3.6.ktr b/separate_failed/filter_3.6.ktr new file mode 100644 index 0000000..3dd4a7d --- /dev/null +++ b/separate_failed/filter_3.6.ktr @@ -0,0 +1,775 @@ + + + + filter_3.6 + + + + Normal + 0 + / + + + in_csv + ${result_location}/${endpoint_name}.csv + input csv path + + + out_csv + ${result_location}/testout_${endpoint_name}.csv + output csv path + + + + + + +
+ + + + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + TRANSNAME + Y + TRANSNAME + + + STATUS + Y + STATUS + + + LINES_READ + Y + LINES_READ + + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + + LINES_UPDATED + Y + LINES_UPDATED + + + + LINES_INPUT + Y + LINES_INPUT + + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + + LINES_REJECTED + Y + LINES_REJECTED + + + + ERRORS + Y + ERRORS + + + STARTDATE + Y + STARTDATE + + + ENDDATE + Y + ENDDATE + + + LOGDATE + Y + LOGDATE + + + DEPDATE + Y + DEPDATE + + + REPLAYDATE + Y + REPLAYDATE + + + LOG_FIELD + Y + LOG_FIELD + + + EXECUTING_SERVER + N + EXECUTING_SERVER + + + EXECUTING_USER + N + EXECUTING_USER + + + CLIENT + N + CLIENT + + + + + +
+ + + + ID_BATCH + Y + ID_BATCH + + + SEQ_NR + Y + SEQ_NR + + + LOGDATE + Y + LOGDATE + + + TRANSNAME + Y + TRANSNAME + + + STEPNAME + Y + STEPNAME + + + STEP_COPY + Y + STEP_COPY + + + LINES_READ + Y + LINES_READ + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + LINES_UPDATED + Y + LINES_UPDATED + + + LINES_INPUT + Y + LINES_INPUT + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + LINES_REJECTED + Y + LINES_REJECTED + + + ERRORS + Y + ERRORS + + + INPUT_BUFFER_ROWS + Y + INPUT_BUFFER_ROWS + + + OUTPUT_BUFFER_ROWS + Y + OUTPUT_BUFFER_ROWS + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + LOGGING_OBJECT_TYPE + Y + LOGGING_OBJECT_TYPE + + + OBJECT_NAME + Y + OBJECT_NAME + + + OBJECT_COPY + Y + OBJECT_COPY + + + REPOSITORY_DIRECTORY + Y + REPOSITORY_DIRECTORY + + + FILENAME + Y + FILENAME + + + OBJECT_ID + Y + OBJECT_ID + + + OBJECT_REVISION + Y + OBJECT_REVISION + + + PARENT_CHANNEL_ID + Y + PARENT_CHANNEL_ID + + + ROOT_CHANNEL_ID + Y + ROOT_CHANNEL_ID + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + TRANSNAME + Y + TRANSNAME + + + STEPNAME + Y + STEPNAME + + + STEP_COPY + Y + STEP_COPY + + + LINES_READ + Y + LINES_READ + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + LINES_UPDATED + Y + LINES_UPDATED + + + LINES_INPUT + Y + LINES_INPUT + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + LINES_REJECTED + Y + LINES_REJECTED + + + ERRORS + Y + ERRORS + + + LOG_FIELD + N + LOG_FIELD + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + METRICS_DATE + Y + METRICS_DATE + + + METRICS_CODE + Y + METRICS_CODE + + + METRICS_DESCRIPTION + Y + METRICS_DESCRIPTION + + + METRICS_SUBJECT + Y + METRICS_SUBJECT + + + METRICS_TYPE + Y + METRICS_TYPE + + + METRICS_VALUE + Y + METRICS_VALUE + + + + + +
+ + 0.0 + 0.0 + + 10000 + 50 + 50 + N + Y + 50000 + Y + + N + 1000 + 100 + + + + + + + + + - + 2021/01/20 11:06:54.110 + - + 2021/01/20 11:06:54.110 + H4sIAAAAAAAAAAMAAAAAAAAAAAA= + N + + + + + + read CSV + Filter rows + Y + + + Filter rows + write result + Y + + + + Filter rows + FilterRows + + Y + + 1 + + none + + + write result + + + + N + + + N + errors + CONTAINS + + + constant + String + 3.6 + -1 + -1 + N + + + + + + + + + + + + + + + + 592 + 112 + Y + + + + read CSV + CsvInput + + Y + + 1 + + none + + + ${in_csv} + in + + N + ; + " +
Y
+ 50000 + N + N + N + N + + + + + file_id + String + + $ + . + , + 23 + -1 + none + + + md_id + String + + $ + . + , + 36 + -1 + none + + + type + String + + $ + . + , + 7 + -1 + none + + + result + String + + $ + . + , + 6 + -1 + none + + + MD5 + String + + + + + -1 + -1 + none + + + error_count + String + + + + + -1 + -1 + none + + + errors + String + + + + + -1 + -1 + none + + + + + + + + + + + + 464 + 112 + Y + + + + write result + TextFileOutput + + Y + + 1 + + none + + + ; + " + N + N +
Y
+
N
+ DOS + None + windows-1252 + + N + out_csv + N + + ${out_csv} + N + Y + + N + N + N + N + N + N + + N + N + N + 0 + + + + file_id + String + + + + + + none + -1 + -1 + + + md_id + String + + + + + + none + -1 + -1 + + + type + String + + + + + + none + -1 + -1 + + + result + String + + + + + + none + -1 + -1 + + + MD5 + String + + + + + + none + -1 + -1 + + + error_count + Integer + + + + + + none + -1 + -1 + + + errors + String + + + + + + none + -1 + -1 + + + + + + + + + + + + 736 + 112 + Y + + + + + + + N + + diff --git a/separate_failed/getfiles.py b/separate_failed/getfiles.py new file mode 100644 index 0000000..c581a69 --- /dev/null +++ b/separate_failed/getfiles.py @@ -0,0 +1,31 @@ +import os, shutil, sys +import csv + +args = sys.argv +endpoint = args[1] +data_location = args[2] +result_location = args[3] + +new_folder = "{0}/retesting-{1}".format(result_location, endpoint) +report_path = args[3] +test_path = "{0}".format(data_location, endpoint) + +if os.path.isdir(new_folder): + shutil.rmtree(new_folder) + +os.mkdir(new_folder) + + +with open('{0}/testout_{1}.csv'.format(result_location, endpoint)) as csv_file: + csv_reader = csv.reader(csv_file, delimiter=';') + line_count = 0 + for row in csv_reader: + if not line_count == 0: + filename = row[0] + if not filename.split("/").__len__() == 1: + if not os.path.isdir(new_folder + '/' + filename.split("/")[0]): + os.mkdir(new_folder + '/' + filename.split("/")[0]) + shutil.copyfile(test_path + '/' + filename + ".xml", new_folder + '/' + filename + ".xml") + + line_count += 1 + diff --git a/separate_failed/intersect.py b/separate_failed/intersect.py new file mode 100644 index 0000000..ad3c863 --- /dev/null +++ b/separate_failed/intersect.py @@ -0,0 +1,77 @@ +import os, sys, csv + +args = sys.argv + +report_total_location = sys.argv[1] +report_error_location = sys.argv[2] +file_errors = sys.argv[3] +file_total = sys.argv[4] +file_create = './temp.csv' + +def create_file(): + with open(file_create, 'w') as create: + create.write('file_id;md_id;type;result;MD5;error_count;errors') + + +def append_line(array): + with open(file_create, 'a') as append: + for line in array: + text = '' + for element in line: + text +=element+";" + append.write('\n'+text[:-1]) + +def update_file(): + os.remove(file_total) + os.rename(file_create, file_total) + +def move_reports(folder): + path_error = report_error_location + '/' + folder + error_html = path_error + '.html' + error_json = path_error + '.json' + + path_total = report_total_location + '/' + folder + total_html = path_total + '.html' + total_json = path_total + '.json' + try: + os.remove(total_html) + except: + None + + try: + os.remove(total_json) + except: + None + + print('moved ', error_html,' - ', error_json, ' to main report total folder') + os.rename(error_html, total_html) + os.rename(error_json, total_json) + + +create_file() + + +with open(file_total, 'r') as fileTotal: + csv_reader_total = csv.reader(fileTotal, delimiter=';') + next(csv_reader_total, None) + array = [] + for total in csv_reader_total: + with open(file_errors, 'r') as fileErrors: + csv_reader_errors = csv.reader(fileErrors, delimiter=';') + next(csv_reader_errors, None) + for error in csv_reader_errors: + if total[0] == error[0]: + print(error[3]) + if not error[3] == "FAILED": + total = error + move_reports(total[0]) + elif "3.6" not in error[6]: + total = error + move_reports(total[0]) + fileErrors.close() + print(total) + array.append(total) + append_line(array) + +update_file() + diff --git a/summarize_errors.ktr b/summarize_errors.ktr new file mode 100644 index 0000000..b7d604e --- /dev/null +++ b/summarize_errors.ktr @@ -0,0 +1,3239 @@ + + + + summarize_errors + + + + Normal + 0 + / + + + path_folder + + + + + results_folder + + + + + + + + +
+ + + + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + TRANSNAME + Y + TRANSNAME + + + STATUS + Y + STATUS + + + LINES_READ + Y + LINES_READ + + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + + LINES_UPDATED + Y + LINES_UPDATED + + + + LINES_INPUT + Y + LINES_INPUT + + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + + LINES_REJECTED + Y + LINES_REJECTED + + + + ERRORS + Y + ERRORS + + + STARTDATE + Y + STARTDATE + + + ENDDATE + Y + ENDDATE + + + LOGDATE + Y + LOGDATE + + + DEPDATE + Y + DEPDATE + + + REPLAYDATE + Y + REPLAYDATE + + + LOG_FIELD + Y + LOG_FIELD + + + EXECUTING_SERVER + N + EXECUTING_SERVER + + + EXECUTING_USER + N + EXECUTING_USER + + + CLIENT + N + CLIENT + + + + + +
+ + + + ID_BATCH + Y + ID_BATCH + + + SEQ_NR + Y + SEQ_NR + + + LOGDATE + Y + LOGDATE + + + TRANSNAME + Y + TRANSNAME + + + STEPNAME + Y + STEPNAME + + + STEP_COPY + Y + STEP_COPY + + + LINES_READ + Y + LINES_READ + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + LINES_UPDATED + Y + LINES_UPDATED + + + LINES_INPUT + Y + LINES_INPUT + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + LINES_REJECTED + Y + LINES_REJECTED + + + ERRORS + Y + ERRORS + + + INPUT_BUFFER_ROWS + Y + INPUT_BUFFER_ROWS + + + OUTPUT_BUFFER_ROWS + Y + OUTPUT_BUFFER_ROWS + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + LOGGING_OBJECT_TYPE + Y + LOGGING_OBJECT_TYPE + + + OBJECT_NAME + Y + OBJECT_NAME + + + OBJECT_COPY + Y + OBJECT_COPY + + + REPOSITORY_DIRECTORY + Y + REPOSITORY_DIRECTORY + + + FILENAME + Y + FILENAME + + + OBJECT_ID + Y + OBJECT_ID + + + OBJECT_REVISION + Y + OBJECT_REVISION + + + PARENT_CHANNEL_ID + Y + PARENT_CHANNEL_ID + + + ROOT_CHANNEL_ID + Y + ROOT_CHANNEL_ID + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + TRANSNAME + Y + TRANSNAME + + + STEPNAME + Y + STEPNAME + + + STEP_COPY + Y + STEP_COPY + + + LINES_READ + Y + LINES_READ + + + LINES_WRITTEN + Y + LINES_WRITTEN + + + LINES_UPDATED + Y + LINES_UPDATED + + + LINES_INPUT + Y + LINES_INPUT + + + LINES_OUTPUT + Y + LINES_OUTPUT + + + LINES_REJECTED + Y + LINES_REJECTED + + + ERRORS + Y + ERRORS + + + LOG_FIELD + N + LOG_FIELD + + + + + +
+ + + ID_BATCH + Y + ID_BATCH + + + CHANNEL_ID + Y + CHANNEL_ID + + + LOG_DATE + Y + LOG_DATE + + + METRICS_DATE + Y + METRICS_DATE + + + METRICS_CODE + Y + METRICS_CODE + + + METRICS_DESCRIPTION + Y + METRICS_DESCRIPTION + + + METRICS_SUBJECT + Y + METRICS_SUBJECT + + + METRICS_TYPE + Y + METRICS_TYPE + + + METRICS_VALUE + Y + METRICS_VALUE + + + + + +
+ + 0.0 + 0.0 + + 10000 + 50 + 50 + N + Y + 50000 + Y + + N + 1000 + 100 + + + + + + + + + - + 2020/04/13 08:46:57.035 + - + 2020/04/13 08:46:57.035 + H4sIAAAAAAAA/wMAAAAAAAAAAAA= + N + + + + + + split, sort + denormalise + Y + + + split, sort 2 + denormalise 2 + Y + + + endpoint + service? + Y + + + service? + split, sort + Y + + + service? + split, sort 2 + Y + + + denormalise 2 + summarize_errors_datasets_tab + Y + + + denormalise + Wait + Y + + + Wait + summarize_errors_service_tab + Y + + + read CSV + endpoint + Y + + + + Wait + BlockUntilStepsFinish + + Y + + 1 + + none + + + + + summarize_errors_datasets_tab + 0 + + + + + + + + + + + + 816 + 32 + Y + + + + denormalise + Denormaliser + + Y + + 1 + + none + + + error + + + endpoint + + + + + errors + total + md_count + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + 3.1 + 3.1 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + 3.2 + 3.2 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + 3.3 + 3.3 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + 3.4 + 3.4 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + 3.5 + 3.5 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + 3.6 + 3.6 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + 3.7 + 3.7 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + 3.8 + 3.8 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + 4.1 + 4.1 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + 5.1 + 5.1 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + 5.2 + 5.2 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + 5.3 + 5.3 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + 5.4 + 5.4 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + 5.5 + 5.5 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + C.1 + C.1 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + C.2 + C.2 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + C.5 + C.5 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + C.6 + C.6 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + C.7 + C.7 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + C.8 + C.8 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + C.9 + C.9 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + C.10 + C.10 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + C.11 + C.11 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + C.12 + C.12 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + C.13 + C.13 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + C.14 + C.14 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + C.15 + C.15 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + C.16 + C.16 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + C.17 + C.17 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + C.18 + C.18 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + C.19 + C.19 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + C.20 + C.20 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + C.21 + C.21 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + C.22 + C.22 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + + + + + + + + + + 688 + 32 + Y + + + + denormalise 2 + Denormaliser + + Y + + 1 + + none + + + error + + + endpoint + + + + + errors + total + md_count + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + 1.1 + 1.1 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + 1.2 + 1.2 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + 1.3 + 1.3 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + 1.4 + 1.4 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + 1.5 + 1.5 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + 1.6 + 1.6 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + 1.7 + 1.7 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + 1.8 + 1.8 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + 1.9 + 1.9 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + 1.10 + 1.10 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + 1.11 + 1.11 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + C.1 + C.1 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + C.2 + C.2 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + C.5 + C.5 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + C.6 + C.6 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + C.7 + C.7 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + C.8 + C.8 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + C.9 + C.9 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + C.10 + C.10 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + C.11 + C.11 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + C.12 + C.12 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + C.13 + C.13 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + C.14 + C.14 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + C.15 + C.15 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + C.16 + C.16 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + C.17 + C.17 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + C.18 + C.18 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + C.19 + C.19 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + C.20 + C.20 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + C.21 + C.21 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + C.22 + C.22 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + 2.1 + 2.1 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + 2.2 + 2.2 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + 2.3 + 2.3 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + 2.4 + 2.4 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + 2.5 + 2.5 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + 2.6 + 2.6 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + 2.7 + 2.7 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + 2.8 + 2.8 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + 2.9 + 2.9 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + 2.10 + '2.10' + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + 2.11 + 2.11 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + M.1 + M.1 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + errors + M.2 + M.2 + Integer + + -1 + -1 + + + + + COUNT_ALL + + + + + + + + + + + + 672 + 192 + Y + + + + endpoint + FieldSplitter + + Y + + 1 + + none + + + filename + . + + + + endpoint + + N + String + + + + + -1 + -1 + + + none + + + + + + + + + + + + 208 + 112 + Y + + + + read CSV + TextFileInput + + Y + + 1 + + none + + + N + N + + + ; + " + N + +
Y
+ 1 +
N
+ 1 + N + 1 + N + 80 + 0 + Y + N + + N + N + + Unix + + Characters + Y + + ${results_folder}\ + INSPIRE[0-9a-z-]*\.csv + + N + N + + + + N + N + CSV + None + + + + + + path + String + + $ + . + , + - + + -1 + 10 + -1 + none + N + + + id + String + + $ + . + , + - + + -1 + 36 + -1 + none + N + + + type + String + + $ + . + , + - + + -1 + 7 + -1 + none + N + + + result + String + + $ + . + , + - + + -1 + 14 + -1 + none + N + + + md5 + String + + $ + . + , + - + + -1 + 32 + -1 + none + N + + + count + String + + + + + + + -1 + -1 + -1 + none + N + + + errors + String + + $ + . + , + - + + -1 + 13 + -1 + none + N + + + 0 + N + N + + + N + + + + + warning + + error + + line + Y + en_US + filename + + + + + + + + + + + + + + + + + 64 + 112 + Y + + + + service? + FilterRows + + Y + + 1 + + none + + + split, sort + split, sort 2 + + + N + + + N + type + = + + + constant + String + service + -1 + -1 + N + + + + + + + + + + + + + + + + 368 + 112 + Y + + + + split, sort + SimpleMapping + + Y + + 1 + + none + + + filename + + + ${Internal.Entry.Current.Directory}/errors_sub.ktr + + + + + + + Y + Y + + + + + + + + Y + N + + + + + Y + + + + + + + + + + + + 544 + 32 + Y + + + + split, sort 2 + SimpleMapping + + Y + + 1 + + none + + + filename + + + ${Internal.Entry.Current.Directory}/errors_sub.ktr + + + + + + + Y + Y + + + + + + + + Y + N + + + + + Y + + + + + + + + + + + + 544 + 192 + Y + + + + summarize_errors_datasets_tab + TypeExitExcelWriterStep + + Y + + 1 + + none + + +
Y
+
N
+ N + A1 + N + 0 + 0 + overwrite + N + N + N + N + Y + + ${path_folder}summarize_errors + xlsx + N + N + N + N + N + N + + dataset + N + Y + N + N + Encrypted + + 0 + reuse + new + + + + + endpoint + String + + endpoint + + + + + N + + + + md_count + Integer + + md_count + + + + + N + + + + 1.1 + Integer + + 1.1 + + + + + N + + + + 1.2 + Integer + + 1.2 + + + + + N + + + + 1.3 + Integer + + 1.3 + + + + + N + + + + 1.4 + Integer + + 1.4 + + + + + N + + + + 1.5 + Integer + + 1.5 + + + + + N + + + + 1.6 + Integer + + 1.6 + + + + + N + + + + 1.7 + Integer + + 1.7 + + + + + N + + + + 1.8 + Integer + + 1.8 + + + + + N + + + + 1.9 + Integer + + 1.9 + + + + + N + + + + 1.10 + Integer + + 1.10 + + + + + N + + + + 1.11 + Integer + + 1.11 + + + + + N + + + + C.1 + Integer + + C.1 + + + + + N + + + + C.2 + Integer + + C.2 + + + + + N + + + + C.5 + Integer + + C.5 + + + + + N + + + + C.6 + Integer + + C.6 + + + + + N + + + + C.7 + Integer + + C.7 + + + + + N + + + + C.8 + Integer + + C.8 + + + + + N + + + + C.9 + Integer + + C.9 + + + + + N + + + + C.10 + Integer + + C.10 + + + + + N + + + + C.11 + Integer + + C.11 + + + + + N + + + + C.12 + Integer + + C.12 + + + + + N + + + + C.13 + Integer + + C.13 + + + + + N + + + + C.14 + Integer + + C.14 + + + + + N + + + + C.15 + Integer + + C.15 + + + + + N + + + + C.16 + Integer + + C.16 + + + + + N + + + + C.17 + Integer + + C.17 + + + + + N + + + + C.18 + Integer + + C.18 + + + + + N + + + + C.19 + Integer + + C.19 + + + + + N + + + + C.20 + Integer + + C.20 + + + + + N + + + + C.21 + Integer + + C.21 + + + + + N + + + + C.22 + Integer + + C.22 + + + + + N + + + + 2.1 + Integer + + 2.1 + + + + + N + + + + 2.2 + Integer + + 2.2 + + + + + N + + + + 2.3 + Integer + + 2.3 + + + + + N + + + + 2.4 + Integer + + 2.4 + + + + + N + + + + 2.5 + Integer + + 2.5 + + + + + N + + + + 2.6 + Integer + + 2.6 + + + + + N + + + + 2.7 + Integer + + 2.7 + + + + + N + + + + 2.8 + Integer + + 2.8 + + + + + N + + + + 2.9 + Integer + + 2.9 + + + + + N + + + + '2.10' + Integer + + '2.10' + + + + + N + + + + 2.11 + Integer + + 2.11 + + + + + N + + + + M.1 + Integer + + M.1 + + + + + N + + + + M.2 + Integer + + M.2 + + + + + N + + + + + + + + + + + + + 864 + 192 + Y + + + + summarize_errors_service_tab + TypeExitExcelWriterStep + + Y + + 1 + + none + + +
Y
+
N
+ N + A1 + N + 0 + 0 + overwrite + N + N + N + N + Y + + ${path_folder}summarize_errors + xlsx + N + N + N + N + N + N + + service + N + Y + N + N + Encrypted + + 0 + reuse + new + + + + + endpoint + String + + endpoint + + + + + N + + + + md_count + Integer + + md_count + + + + + N + + + + 3.1 + Integer + + 3.1 + + + + + N + + + + 3.2 + Integer + + 3.2 + + + + + N + + + + 3.3 + Integer + + 3.3 + + + + + N + + + + 3.4 + Integer + + 3.4 + + + + + N + + + + 3.5 + Integer + + 3.5 + + + + + N + + + + 3.6 + Integer + + 3.6 + + + + + N + + + + 3.7 + Integer + + 3.7 + + + + + N + + + + 3.8 + Integer + + 3.8 + + + + + N + + + + 4.1 + Integer + + 4.1 + + + + + N + + + + 5.1 + Integer + + 5.1 + + + + + N + + + + 5.2 + Integer + + 5.2 + + + + + N + + + + 5.3 + Integer + + 5.3 + + + + + N + + + + 5.4 + Integer + + 5.4 + + + + + N + + + + 5.5 + Integer + + 5.5 + + + + + N + + + + C.1 + Integer + + C.1 + + + + + N + + + + C.2 + Integer + + C.2 + + + + + N + + + + C.5 + Integer + + C.5 + + + + + N + + + + C.6 + Integer + + C.6 + + + + + N + + + + C.7 + Integer + + C.7 + + + + + N + + + + C.8 + Integer + + C.8 + + + + + N + + + + C.9 + Integer + + C.9 + + + + + N + + + + C.10 + Integer + + C.10 + + + + + N + + + + C.11 + Integer + + C.11 + + + + + N + + + + C.12 + Integer + + C.12 + + + + + N + + + + C.13 + Integer + + C.13 + + + + + N + + + + C.14 + Integer + + C.14 + + + + + N + + + + C.15 + Integer + + C.15 + + + + + N + + + + C.16 + Integer + + C.16 + + + + + N + + + + C.17 + Integer + + C.17 + + + + + N + + + + C.18 + Integer + + C.18 + + + + + N + + + + C.19 + Integer + + C.19 + + + + + N + + + + C.20 + Integer + + C.20 + + + + + N + + + + C.21 + Integer + + C.21 + + + + + N + + + + C.22 + Integer + + C.22 + + + + + N + + + + + + + + + + + + + 944 + 32 + Y + + + + + + + N + +