Load via workflow with incoming archive

In this page:

Set hashsum for archive only

To send hashsum for archive only, just need to set archive name in WorkflowData task parameter and set filesHashSum task parameter with hashsum value of archive:

<taskParameter>
   <name>filesHashSum</name>
   <dataType>S</dataType>
   <value>7ea0d2419acb225cc53c4cb7468653ae183b57f07558e1200f18b71e219bee73</value>
</taskParameter>

Send the RTR to eagle_ml-2-0_default_cm_control_message stream and wait while the workflow is finished.

Click to expand the RTR example:

<EagleML xmlns="http://www.eagleinvsys.com/2011/EagleML-2-0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:type="RunTaskRequest" eaglemlVersion="2-0" xsi:schemaLocation="http://www.eagleinvsys.com/2011/EagleML-2-0 eagleml-main-2-0.xsd" eaglemlType="RunTaskRequest">
<header>
<messageId>TST_TSR_ACK_RENAME</messageId>
<sentBy>http://www.eagleinvsys.com</sentBy>
<sendTo>http://www.eagleinvsys.com/eagle_ml-2-0_default_cm_control_message</sendTo>
<creationTimestamp/>
</header>
<taskIdentifier>
<correlationId>cm_wrf_300817_43</correlationId>
<businessTaskId>cm_wrf_300817_43</businessTaskId>
</taskIdentifier>
<taskTypeEnum>LOAD</taskTypeEnum>
<taskParameters>
<taskParameter>
<name>StreamName</name>
<dataType>S</dataType>
<value>eagle_ml-2-0_default_cm_execwkfl</value>
</taskParameter>
<taskParameter>
<name>ActionType</name>
<dataType>S</dataType>
<value>EXECUTE</value>
</taskParameter>
<taskParameter>
<name>WorkflowName</name>
<dataType>S</dataType>
<value>eagle_wrf_generic_load</value>
</taskParameter>
<taskParameter>
<name>WorkflowData</name>
<dataType>S</dataType>
<value>EAGLE_ML_DT040817_CSV.zip</value>
</taskParameter>
<taskParameter>
<name>DeliveryMethod</name>
<dataType>S</dataType>
<value>FILE</value>
</taskParameter>
<taskParameter>
<name>filesHashSum</name>
<dataType>S</dataType>
<value>7ea0d2419acb225cc53c4cb7468653ae183b57f07558e1200f18b71e219bee73</value>
</taskParameter>
</taskParameters>
</EagleML>

Finished with success

Finished with hashsum calculation error

The error occurs during the first eagle_ml-2-0_default_cm_execwkfl stream processing:

Error description in Final Status tab:

Set hashsums for archive and files

To check hashsums for the archive and its files, set filesHashSum task parameter with archive and files names and its hashsum values separated by commas:
archive_or_file_name1,hashsum1,archive_or_file_name2,hashsum2,…

<taskParameter>
   <name>filesHashSum</name>
   <dataType>S</dataType>
   <value>EAGLE_ML_DT040817_CSV.zip,7ea0d2419acb225cc53c4cb7468653ae183b57f07558e1200f18b71e219bee73,DT040817_GENERICSMF_.xml,3711b35c45faa6b348a44441253d244e17f2ac84ee932975899dd36e0997022a,EAGLE_CSV_GENERICSMFCSV_.csv,71656e6dac5cf1b9dd303b72efb401e21a8deacb69d89583b9d59cfd2808ec2e</value>
</taskParameter>

Send the RTR to eagle_ml-2-0_default_cm_control_message stream and wait while the workflow is finished.

Click to expand the RTR example:

<EagleML xmlns="http://www.eagleinvsys.com/2011/EagleML-2-0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:type="RunTaskRequest" eaglemlVersion="2-0" xsi:schemaLocation="http://www.eagleinvsys.com/2011/EagleML-2-0 eagleml-main-2-0.xsd" eaglemlType="RunTaskRequest">
<header>
<messageId>TST_TSR_ACK_RENAME</messageId>
<sentBy>http://www.eagleinvsys.com</sentBy>
<sendTo>http://www.eagleinvsys.com/eagle_ml-2-0_default_cm_control_message</sendTo>
<creationTimestamp/>
</header>
<taskIdentifier>
<correlationId>cm_wrf_300817_43</correlationId>
<businessTaskId>cm_wrf_300817_43</businessTaskId>
</taskIdentifier>
<taskTypeEnum>LOAD</taskTypeEnum>
<taskParameters>
<taskParameter>
<name>StreamName</name>
<dataType>S</dataType>
<value>eagle_ml-2-0_default_cm_execwkfl</value>
</taskParameter>
<taskParameter>
<name>ActionType</name>
<dataType>S</dataType>
<value>EXECUTE</value>
</taskParameter>
<taskParameter>
<name>WorkflowName</name>
<dataType>S</dataType>
<value>eagle_wrf_generic_load</value>
</taskParameter>
<taskParameter>
<name>WorkflowData</name>
<dataType>S</dataType>
<value>EAGLE_ML_DT040817_CSV.zip</value>
</taskParameter>
<taskParameter>
<name>DeliveryMethod</name>
<dataType>S</dataType>
<value>FILE</value>
</taskParameter>
<taskParameter>
<name>filesHashSum</name>
<dataType>S</dataType>
<value>EAGLE_ML_DT040817_CSV.zip,7ea0d2419acb225cc53c4cb7468653ae183b57f07558e1200f18b71e219bee73,DT040817_GENERICSMF_.xml,3711b35c45faa6b348a44441253d244e17f2ac84ee932975899dd36e0997022a,EAGLE_CSV_GENERICSMFCSV_.csv,71656e6dac5cf1b9dd303b72efb401e21a8deacb69d89583b9d59cfd2808ec2e</value>
</taskParameter>
</taskParameters>
</EagleML>

Finished with success

Finished with hashsum calculation error

Error occurs during archive hashsum calculation

In this case the error occurs during the first eagle_ml-2-0_default_cm_execwkfl stream processing:

Error description in Final Status tab:

Error occurs during files from archive hashsum calculation (eagle_wrf_generic_load workflow execution)

In this case the error occurs during the first eagle_ml-2-0_default_cm_unpacker_exec stream processing in generic_load_unpacker step:

In case of eagle_wrf_generic_load workflow both steps will be failed.
Error description in Final Status tab for generic_load_unpacker step:

Also for eagle_wrf_generic_load the error will be in Final Status of initial step:

Error occurs during files from archive hashsum calculation (custom workflow execution)

Error occurs during the first eagle_ml-2-0_default_cm_unpacker_exec stream processing in generic_load_unpacker step:

In case of custom workflow execution only unpacker step will be failed.
The error description check in Final Status tab for generic_load_unpacker step:

Set hashsums for files in archive only

To send hashsum for files in archive only, set filesHashSum task parameter with files names and its hashsum values separated by comma:
file_name1,hashsum1,file_name2,hashsum2,…

<taskParameter>
   <name>filesHashSum</name>
   <dataType>S</dataType>
   <value>DT040817_GENERICSMF_.xml,3711b35c45faa6b348a44441253d244e17f2ac84ee932975899dd36e0997022a,EAGLE_CSV_GENERICSMFCSV_.csv,71656e6dac5cf1b9dd303b72efb401e21a8deacb69d89583b9d59cfd2808ec2e</value>
</taskParameter>

Send the RTR to eagle_ml-2-0_default_cm_control_message stream and wait while the workflow is finished.

Click to expand the RTR example:

<EagleML xmlns="http://www.eagleinvsys.com/2011/EagleML-2-0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:type="RunTaskRequest" eaglemlVersion="2-0" xsi:schemaLocation="http://www.eagleinvsys.com/2011/EagleML-2-0 eagleml-main-2-0.xsd" eaglemlType="RunTaskRequest">
<header>
<messageId>TST_TSR_ACK_RENAME</messageId>
<sentBy>http://www.eagleinvsys.com</sentBy>
<sendTo>http://www.eagleinvsys.com/eagle_ml-2-0_default_cm_control_message</sendTo>
<creationTimestamp/>
</header>
<taskIdentifier>
<correlationId>cm_wrf_300817_43</correlationId>
<businessTaskId>cm_wrf_300817_43</businessTaskId>
</taskIdentifier>
<taskTypeEnum>LOAD</taskTypeEnum>
<taskParameters>
<taskParameter>
<name>StreamName</name>
<dataType>S</dataType>
<value>eagle_ml-2-0_default_cm_execwkfl</value>
</taskParameter>
<taskParameter>
<name>ActionType</name>
<dataType>S</dataType>
<value>EXECUTE</value>
</taskParameter>
<taskParameter>
<name>WorkflowName</name>
<dataType>S</dataType>
<value>eagle_wrf_generic_load</value>
</taskParameter>
<taskParameter>
<name>WorkflowData</name>
<dataType>S</dataType>
<value>EAGLE_ML_DT040817_CSV.zip</value>
</taskParameter>
<taskParameter>
<name>DeliveryMethod</name>
<dataType>S</dataType>
<value>FILE</value>
</taskParameter>
<taskParameter>
<name>filesHashSum</name>
<dataType>S</dataType>
<value>DT040817_GENERICSMF_.xml,3711b35c45faa6b348a44441253d244e17f2ac84ee932975899dd36e0997022a,EAGLE_CSV_GENERICSMFCSV_.csv,71656e6dac5cf1b9dd303b72efb401e21a8deacb69d89583b9d59cfd2808ec2e</value>
</taskParameter>
</taskParameters>
</EagleML>

Finished with success

Error occurs during files from archive hashsum calculation (eagle_wrf_generic_load workflow execution)

In this case the error occurs during the first eagle_ml-2-0_default_cm_unpacker_exec stream processing in generic_load_unpacker step:

In case of eagle_wrf_generic_load workflow both steps will be failed.
Error description in Final Status tab for generic_load_unpacker step:

Also for eagle_wrf_generic_load the error will be in Final Status of initial step:

Error occurs during files from archive hashsum calculation (custom workflow execution)

Error occurrs during the first eagle_ml-2-0_default_cm_unpacker_exec stream processing in generic_load_unpacker step:

In case of custom workflow execution only unpacker step will be failed.
The error description check in Final Status tab for generic_load_unpacker step:

Error processing with task parameter consolidatedTSR=1

To view all statuses in final status set task parameter consolidatedTSR with value 1 in RTR.

<taskParameter>
	<name>filesHashSum</name>
	<dataType>S</dataType><value>EAGLE_ML_DT040817_CSV.zip,7ea0d2419acb225cc53c4cb7468653ae183b57f07558e1200f18b71e219bee73,DT040817_GENERICSMF_.xml,3711b35c45faa6b348a44441253d244e17f2ac84ee932975899dd36e0997022a,EAGLE_CSV_GENERICSMFCSV_.csv,71656e6dac5cf1b9dd303b72efb401e21a8deacb69d89583b9d59cfd2808ec2e</value>
</taskParameter>
<taskParameter>
	<name>CreateConsolidatedTSR</name>
	<dataType>S</dataType>
	<value>1</value>
</taskParameter>

Click to expand the RTR example:

<EagleML xmlns="http://www.eagleinvsys.com/2011/EagleML-2-0"  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:type="RunTaskRequest" eaglemlVersion="2-0"  xsi:schemaLocation="http://www.eagleinvsys.com/2011/EagleML-2-0 eagleml-main-2-0.xsd" eaglemlType="RunTaskRequest">
<header>
	<messageId>TST_TSR_ACK_RENAME</messageId>
	<sentBy>http://www.eagleinvsys.com</sentBy>
	<sendTo>http://www.eagleinvsys.com/eagle_ml-2-0_default_cm_control_message</sendTo>
	<creationTimestamp/>
</header>
<taskIdentifier>
	<correlationId>cm_wrf_300817_43</correlationId>
	<businessTaskId>cm_wrf_300817_43</businessTaskId>
</taskIdentifier>
<taskTypeEnum>LOAD</taskTypeEnum>
<taskParameters>
	<taskParameter>
		<name>StreamName</name>
		<dataType>S</dataType>
		<value>eagle_ml-2-0_default_cm_execwkfl</value>
	</taskParameter>
	<taskParameter>
		<name>ActionType</name>
		<dataType>S</dataType>
		<value>EXECUTE</value>
	</taskParameter>
	<taskParameter>
		<name>WorkflowName</name>
		<dataType>S</dataType>
		<value>eagle_wrf_generic_load</value>
	</taskParameter>
	<taskParameter>
		<name>WorkflowData</name>
		<dataType>S</dataType>
		<value>EAGLE_ML_DT040817_CSV.zip</value>
	</taskParameter>
	<taskParameter>
		<name>DeliveryMethod</name>
		<dataType>S</dataType>
		<value>FILE</value>
	</taskParameter>
	<taskParameter>
		<name>filesHashSum</name>
		<dataType>S</dataType>
<value>EAGLE_ML_DT040817_CSV.zip,7ea0d2419acb225cc53c4cb7468653ae183b57f07558e1200f18b71e219bee73,DT040817_GENERICSMF_.xml,3711b35c45faa6b348a44441253d244e17f2ac84ee932975899dd36e0997022a,EAGLE_CSV_GENERICSMFCSV_.csv,71656e6dac5cf1b9dd303b72efb401e21a8deacb69d89583b9d59cfd2808ec2e</value>
	</taskParameter>
<taskParameter>
		<name>CreateConsolidatedTSR</name>
		<dataType>S</dataType>
		<value>1</value>
	</taskParameter>
</taskParameters>
</EagleML>

Error occurs during archive hashsum calculation

In this case the error occurs during the first eagle_ml-2-0_default_cm_execwkfl stream processing:

Error description in Final Status tab:

Error occurs during files from archive hashsum calculation

In this case the error occurs during the first eagle_ml-2-0_default_cm_unpacker_exec stream processing in generic_load_unpacker step. The initial step has FAILED status as well:

Consolidated status description in Final Status of initial step: