SPL File TestShellPipeBadScript2.spl

Toolkits > SampleShellPipe 1.1.0 > sample > TestShellPipeBadScript2.spl

Content

Operators

• TestShellPipeBadScript2: This sample application executes a Perl script containing a syntax error with the ShellPipe operator, and logs the error messages from the Perl interpreter in the Streams application trace.

Composites

public composite TestShellPipeBadScript2

This sample application executes a Perl script containing a syntax error with the ShellPipe operator, and logs the error messages from the Perl interpreter in the Streams application trace.

The script can be tested independently of Streams by entering these commands at a Linux prompt:

cd .../samples/SampleShellPipe
cat ./data/ozymandias.txt | ./etc/badscript.pl

Parameters

• inputFile: specifies an input file containing lines of text that will be written to a script as its STDIN. The default input file contains a short poem published in 1818 by Percy Bysshe Shelley.
• scriptPath: the path to the script file
• shellCommand: specifies the shell command that will be excuted by the ShellPipe operator. The default command is a Perl script that contains a syntax error.
• rate: the rate of the input tuple stream

SPL Source Code

 composite TestShellPipeBadScript2 {
 
     param
     expression<rstring> $inputFile: dataDirectory() + "/ozymandias.txt";
     expression<rstring> $scriptPath: dataDirectory() + "/../etc/"; //consider to use getApplicationDir() / but so it works also in product version 3.x
     expression<rstring> $shellCommand: getSubmissionTimeValue("shellCommand", "badscript.pl");
     expression<float64> $rate: (float64)getSubmissionTimeValue("rate", "1000000.0");
 
     graph
 
 
     // create a stream of text lines for the ShellPipe operators below to consume
     stream<rstring inputLine> InputStream = FileSource() {
     param
         file: $inputFile;
         format: line; }
     stream<rstring inputLine> InputStreamDelayed = Throttle(InputStream) { param rate : $rate; includePunctuations: true; }
     () as DebugInputStream = FileSink(InputStreamDelayed) { param file: "debug.TestShellPipeBadScript.InputStream.out"; format: txt; hasDelayField: true; flush: 1u; writePunctuations: true; }
 
     
 
     // try to execute a Perl script containing a syntax error
     ( stream<rstring stdoutLine> STDOUTStream ;
       stream<rstring stderrLine> STDERRStream ) = ShellPipe(InputStreamDelayed) {
     param
         abortOnError: true;
         command: $scriptPath + $shellCommand;  }
     () as DebugSTDOUTStream = FileSink(STDOUTStream) { param file: "debug.TestShellPipeBadScript.STDOUTStream.out"; format: txt; hasDelayField: true; flush: 1u; writePunctuations: true; }
     () as DebugSTDERRStream = FileSink(STDERRStream) { param file: "debug.TestShellPipeBadScript.STDERRStream.out"; format: txt; hasDelayField: true; flush: 1u; writePunctuations: true; }
 
 
     // log STDERR lines to Streams application trace
     () as LogSTDERRStream = Custom(STDERRStream as In) {
     logic onTuple In: {
           appTrc(Trace.info, "STDERR from command '" + $shellCommand + "': " + stderrLine); } }
 
     config
         restartable : true;
 
 }