Average solar wind speed at ACE

None

if(status.matches(".*ERROR.*")){
 throw new Exception("error");
}
/ResultInfo/resultURI
url = url_list.get(0)
url_out = url_list.get(0).replaceFirst(".xml","data.asc")
BufferedReader getReader (String fileUrl, String encoding) throws IOException {
		InputStreamReader reader;
		try {
			if (encoding == null) {
				reader = new FileReader(fileUrl);
			} else {
				reader = new InputStreamReader(new FileInputStream(fileUrl),encoding); 
			}
		}
		catch (FileNotFoundException e) {
			// try a real URL instead
			URL url = new URL(fileUrl);
			if (encoding == null) {
				reader = new InputStreamReader (url.openStream());
			} else {
				reader = new InputStreamReader (url.openStream(), encoding);
			}
		}
		return new BufferedReader(reader);
	}


StringBuffer sb = new StringBuffer(4000);

if (encoding == void) {
	encoding = null;
}

BufferedReader in = getReader(fileurl, encoding);
String str;
String lineEnding = System.getProperty("line.separator");

while ((str = in.readLine()) != null) {
	sb.append(str);
	sb.append(lineEnding);
}
in.close();
filecontents = sb.toString();
  

String	content	=	text;
String[]	lines		=	content.split("\\n");

double[]	velocities	=	new double[lines.length-2];
double	vel_tot		=	0;
double	vel_av		=	0;

int	samplesNumber	=	0;
for(int n = 2; n < lines.length; n++)
{
	String[]	values	=	lines[n].split("\\s+");				
	System.out.println("Velocity   [" + n + "] : " + values[1]);
	if(!Double.valueOf(values[1]).isNaN())				
	{
		velocities[samplesNumber]	=	Double.valueOf(values[1]);
		vel_tot			+=	Double.valueOf(values[1]);	
		samplesNumber++;
	}								
}
vel_av		=	vel_tot/samplesNumber;
debug=content;

Name	Description
STARTTIME	starttime of time intervall
ENDTIME	endtime of time interval

Name	Type	Description
LongTimeQuery_output	xmlsplitter
GetStatus	wsdl	Wsdl http://manunja.cesr.fr/Amda-Helio/WebServices/HelioLongQueryService.wsdl Wsdl Operation GetStatus
GetStatus_input	xmlsplitter
GetStatus_output	xmlsplitter
GetResult	wsdl	Wsdl http://manunja.cesr.fr/Amda-Helio/WebServices/HelioLongQueryService.wsdl Wsdl Operation GetResult
GetResult_input	xmlsplitter
GetResult_output	xmlsplitter
ExceptionHandling	beanshell	Script if(status.matches(".ERROR.")){ throw new Exception("error"); }
LongTimeQuery	wsdl	Wsdl http://manunja.cesr.fr/Amda-Helio/WebServices/HelioLongQueryService.wsdl Wsdl Operation LongTimeQuery
LongTimeQuery_input	xmlsplitter
XPath_Service	xpath	Xpath Expression /ResultInfo/resultURI
Beanshell	beanshell	Script url = url_list.get(0)
Url_to_dataurl	beanshell	modify URL to the URL where the data resides. Script url_out = url_list.get(0).replaceFirst(".xml","data.asc")
Read_Text_File	localworker	Script BufferedReader getReader (String fileUrl, String encoding) throws IOException { InputStreamReader reader; try { if (encoding == null) { reader = new FileReader(fileUrl); } else { reader = new InputStreamReader(new FileInputStream(fileUrl),encoding); } } catch (FileNotFoundException e) { // try a real URL instead URL url = new URL(fileUrl); if (encoding == null) { reader = new InputStreamReader (url.openStream()); } else { reader = new InputStreamReader (url.openStream(), encoding); } } return new BufferedReader(reader); } StringBuffer sb = new StringBuffer(4000); if (encoding == void) { encoding = null; } BufferedReader in = getReader(fileurl, encoding); String str; String lineEnding = System.getProperty("line.separator"); while ((str = in.readLine()) != null) { sb.append(str); sb.append(lineEnding); } in.close(); filecontents = sb.toString();
Beanshell_AverageSpeed	beanshell	Script String content = text; String[] lines = content.split("\\n"); double[] velocities = new double[lines.length-2]; double vel_tot = 0; double vel_av = 0; int samplesNumber = 0; for(int n = 2; n < lines.length; n++) { String[] values = lines[n].split("\\s+"); System.out.println("Velocity [" + n + "] : " + values[1]); if(!Double.valueOf(values[1]).isNaN()) { velocities[samplesNumber] = Double.valueOf(values[1]); vel_tot += Double.valueOf(values[1]); samplesNumber++; } } vel_av = vel_tot/samplesNumber; debug=content;
Text_constant	stringconstant	Value ACE

Name	Description	Inputs	Outputs
ExceptionHandling		status
Beanshell		url_list	url
Url_to_dataurl	modify URL to the URL where the data resides.	url_list	url_out
Beanshell_AverageSpeed		text	debug vel_av

Name	Description
url
average_sw_speed

Source	Sink
GetStatus_input:output	GetStatus:parameters
LongTimeQuery_output:ID	GetStatus_input:ID
GetStatus:parameters	GetStatus_output:input
GetResult_input:output	GetResult:parameters
LongTimeQuery_output:ID	GetResult_input:ID
GetResult:parameters	GetResult_output:input
GetStatus_output:Status	ExceptionHandling:status
LongTimeQuery_input:output	LongTimeQuery:parameters
ENDTIME	LongTimeQuery_input:ENDTIME
STARTTIME	LongTimeQuery_input:STARTTIME
Text_constant:value	LongTimeQuery_input:FROM
GetResult_output:ResultInfo	XPath_Service:xml_text
XPath_Service:nodelist	Beanshell:url_list
Beanshell:url	Url_to_dataurl:url_list
Url_to_dataurl:url_out	Read_Text_File:fileurl
Read_Text_File:filecontents	Beanshell_AverageSpeed:text
LongTimeQuery:parameters	LongTimeQuery_output:input
Beanshell:url	url
Beanshell_AverageSpeed:vel_av	average_sw_speed

Average solar wind speed at ACE

Preview

Run

Run this Workflow in the Taverna Workbench...

Workflow Components

Wsdl

Wsdl Operation

Wsdl

Wsdl Operation

Script

Wsdl

Wsdl Operation

Xpath Expression

Script

Script

Script

Script

Value

Reviews (0)

Comments (0)

Other workflows that use similar services (6)