You cannot create external process (like the popen function) on Cloudplex via the Script Snap or custom Snap. While external process creation on Groundplex is possible, this can be disabled upon your request to support@snaplogic.com.

This example requires that an input view be defined for it to work.

package com.snaplogic.scripting.language;

import java.util.Iterator;

/**
 * ScriptHook is the interface that should be implemented as a callback mechanism for
 * ExecuteScript snap to call into the script.
*/

public interface ScriptHook {

    /**
     * Scripts should implement this method to provide application logic.
     */
    void execute();

    /**
     * Scripts should implement this method to cleanup any resources allocated in execute().
     */
    void cleanup();

    /**
     * Input is interface that is used by the script to read input from the snap's input view.
     */
    interface Input extends Iterator<Object> {
    }

    /**
     * Output is interface that is used by the script to send output data to the snap output view.
     */
    interface Output {

        /**
         * Write the data to the snap output.
         *
         * @param data
         */
        void write(Object data);

        /**
         * Write the data that was generated for the given incoming data to the snap output.
         * This method carries the lineage data forward.
         *
         * @param incomingData
         * @param data
         */
        void write(Object incomingData, Object data);
    }

    /**
     * Error is interface that is used by the script to send error data to snap error view.
     */
    interface Error extends Output {
    }
}

• The paths listed in python.path can be .jar files (Java libraries), directories containing Python libraries (compatible with Python 2.7), or .zip files packaging those Python libraries. For more on using the .jython file, see Jython Registry.

• The python.path variable is Jython's version of CPython’s PYTHONPATH variable. To learn more about the PYTHONPATH, see the official Python documentation.

• If you are using multiple Groundplex nodes then you must add the package/JAR files in each of those nodes.

• You can import third party libraries only on Groundplex nodes.

script = {
   execute : function() {
       var fruits = ["apple", "banana", "cherry"]
       var map = {"fruits" : fruits}
       output.write(map)
   }
}
var hook = new com.snaplogic.scripting.language.ScriptHook(script)

This example requires an input view be defined in order for it to work.

from com.snaplogic.scripting.language import ScriptHook
 
class TransformScript(ScriptHook):
   def __init__(self, input, output, error, log):
       self.input = input
       self.output = output
       self.error = error
       self.log = log
 
   def execute(self):
       self.log.info("Executing Transform script")
      
       while self.input.hasNext():
           data = self.input.next()
           data["firstLast"] = "%s-%s" %(data["first"],data["last"])
           data["firstLast2"] = data["first"] + data["last"]
          
           data["numberMath"] = data["counter"] + 22
           data["numberMath2"] = data["counter"] + 23
 
           data["dateMonthPlusOne"] = data["birthday"].plusMonths(1)
          
           data["numberMathType"] = type(data["counter"])
           data["dateType"] = type(data["birthday"])
          
           try:
               data["mathTryCatch"] = data["counter2"] + 33
               self.output.write(data)
           except Exception as e:
               data["errorMessage"] = e.message
               self.error.write(data)
          
       self.log.info("Finished executing the Transform script")
 
hook = TransformScript(input, output, error, log)

from com.snaplogic.scripting.language import ScriptHook
from random import randint
from time import sleep
 
class TransformScript(ScriptHook):
   def __init__(self, input, output, error, log):
       self.input = input
       self.output = output
       self.error = error
       self.log = log
   def execute(self):
       self.log.info("Executing Transform script")
       i = 1
       while self.input.hasNext():
           data = self.input.next()
           sleep(randint(1,10))
           map = {"out": data}
           self.output.write(map)
       self.log.info("Finished executing the Transform script")
hook = TransformScript(input, output, error, log)

// Ensure compatibility with both JDK 7 and 8 JSR-223 Script Engines
try { load("nashorn:mozilla_compat.js"); } catch(e) { }
 
script = {
  execute : function() {
    while (input.hasNext()) {
      var in_data = input.next()
      var new_data = {}
      var keyArray = in_data.keySet().toArray()
      for (var index in keyArray) {
        var key = keyArray[index]
        new_data[key] = in_data.get(key)
      }
 
      new_data.firstLast = new_data.first + "-" + new_data.last
      new_data.firstLast2 = new_data.first + in_data.get("last")
      new_data.numberMath = (new_data.counter + 22) | 0
      new_data.numberMath2 = new_data.counter + 23
      new_data.dateMath = new_data.birthday.plusMonths(1).toString()
      
      new_data.mathType = typeof(new_data.counter)      
      new_data.dateType = typeof(new_data.birthday)              
 
      output.write(new_data)
    }
   }  
};
var hook = new com.snaplogic.scripting.language.ScriptHook(script)

class MyScript
    include com.snaplogic.scripting.language.ScriptHook
    attr_reader :log, :input, :output, :error
    def initialize(log, input, output, error)
        @log = log
        @input = input
        @output = output
        @error = error
        @array = [java.lang.Integer.valueOf(1), java.lang.Integer.valueOf(2)]
        
    end

    def execute()
  
        while input.hasNext()  do
          data = input.next()
        
            data["firstLast2"] = data["first"] + data["last"]
            
            data["numberMath"] = data["counter"] + 22
            data["numberMath2"] = data["counter"] + 23
            data["dateMonthPlusOne"] = data["birthday"].plusMonths(1)
   
            begin
                data["mathTryCatch"] = data["counter"] + 33
                output.write(data)
            rescue Exception=>e
                data["errorMessage"] = e.message
                error.write(data)
            end
        end

    end 
end
$hook = MyScript.new($log, $input, $output, $error)