retrive dpas data for all ics instruments for only a limited number (3 random) HEC event data
Created: 2010-09-14 14:24:20
Last updated: 2010-09-14 14:24:24
This workflow demonstrates the standard query where events for a period of time are requested from the HEC service, available instruments for this time come from the ICS and data only for the times of the events are requested from the DPAS.
In this version data from only 3 random events (out of the HEC list) will be requested from the DPAS.
Preview
Run
Run this Workflow in the Taverna Workbench...
Workflow Components
Authors (1)
Titles (2)
retrive dpas data for all ics instruments for only a limited number (3 random) HEC event data |
retrive dpas data for all ics instruments for HEC event data |
Descriptions (1)
This workflow demonstrates the standard query where events for a period of time are requested from the HEC service, available instruments for this time come from the ICS and data only for the times of the events are requested from the DPAS.
In this version data from only 3 random events (out of the HEC list) will be requested from the DPAS. |
Dependencies (0)
Inputs (3)
Name |
Description |
HEC_Table |
HEC table names - catalogue which should be used
HEC table names - catalogue which should be used
more info at: http://hec.ts.astro.it/sec_ui.php
|
ENDTIME |
end time for event search - standard format
2004-01-12T12:00:00
|
STARTTIME |
start time for search - standard format
|
Processors (10)
Name |
Type |
Description |
HEC |
wsdl |
Wsdlhttp://140.105.77.30:8080/helio-hec-r3/HelioTavernaService?wsdlWsdl OperationQuery |
HEC_query |
xmlsplitter |
|
Retrieve_all_data_for_all_instruments_for_a_given_periode_of_time |
workflow |
|
Extracting_start_time |
workflow |
|
Extracting_end_time |
workflow |
|
HEC_STARTTIME |
stringconstant |
Valuetime_start |
HEC_ENDTIME |
stringconstant |
Valuetime_end |
reduce_list_to_limit |
beanshell |
Scriptimport java.util.Random;
reduced_start=start_date;
reduced_end=end_date;
Random generator = new Random();
while(reduced_start.size()>Integer.parseInt(max)){
int randomIndex = generator.nextInt( reduced_start.size() );
reduced_start.remove(randomIndex);
reduced_end.remove(randomIndex);
} |
max_value |
stringconstant |
Value3 |
Flatten_List |
localworker |
Scriptflatten(inputs, outputs, depth) {
for (i = inputs.iterator(); i.hasNext();) {
element = i.next();
if (element instanceof Collection && depth > 0) {
flatten(element, outputs, depth - 1);
} else {
outputs.add(element);
}
}
}
outputlist = new ArrayList();
flatten(inputlist, outputlist, 1); |
Beanshells (4)
Name |
Description |
Inputs |
Outputs |
reduce_list_to_limit |
|
start_date
end_date
max
|
reduced_start
reduced_end
|
Beanshell |
|
columnName
|
xPath
|
create_standard_names |
|
observatory
instrument
|
HELIO_instrument
|
create_DPAS_input_lists |
|
startdates
enddates
instruments
|
startdatesout
enddatesout
instrumentsout
|
Outputs (2)
Name |
Description |
HEC_VOTable |
|
DPAS_VOTable |
|
Datalinks (18)
Source |
Sink |
HEC_query:output |
HEC:query |
HEC_Table |
HEC_query:FROM |
ENDTIME |
HEC_query:ENDTIME |
STARTTIME |
HEC_query:STARTTIME |
STARTTIME |
Retrieve_all_data_for_all_instruments_for_a_given_periode_of_time:STARTTIME |
ENDTIME |
Retrieve_all_data_for_all_instruments_for_a_given_periode_of_time:ENDTIME |
reduce_list_to_limit:reduced_end |
Retrieve_all_data_for_all_instruments_for_a_given_periode_of_time:HEC_ENDTIME |
reduce_list_to_limit:reduced_start |
Retrieve_all_data_for_all_instruments_for_a_given_periode_of_time:HEC_STARTTIME |
HEC:response |
Extracting_start_time:VOTable |
HEC_STARTTIME:value |
Extracting_start_time:VOTable_columnName |
HEC:response |
Extracting_end_time:VOTable |
HEC_ENDTIME:value |
Extracting_end_time:VOTable_columnName |
max_value:value |
reduce_list_to_limit:max |
Extracting_end_time:VOTable_value_list |
reduce_list_to_limit:end_date |
Extracting_start_time:VOTable_value_list |
reduce_list_to_limit:start_date |
Retrieve_all_data_for_all_instruments_for_a_given_periode_of_time:DPAS_response |
Flatten_List:inputlist |
HEC:response |
HEC_VOTable |
Flatten_List:outputlist |
DPAS_VOTable |
Uploader
License
All versions of this Workflow are
licensed under:
Version 1
(of 1)
Credits (1)
(People/Groups)
Attributions (1)
(Workflows/Files)
Shared with Groups (1)
Featured In Packs (0)
None
Log in to add to one of your Packs
Attributed By (0)
(Workflows/Files)
None
Favourited By (0)
No one
Statistics
Other workflows that use similar services
(7)
Only the first 2 workflows that use similar services are shown. View all workflows that use these services.
Comments (0)
No comments yet
Log in to make a comment