Skip to end of banner
Go to start of banner

Script

Skip to end of metadata
Go to start of metadata

You are viewing an old version of this page. View the current version.

Compare with Current View Page History

« Previous Version 67 Current »

In this article

Overview

You can use the Script Snap to execute Javascript, Python, or Ruby scripts using the JVM ScriptEngine mechanism. Accounts are not required to work with this Snap.

You cannot create external process (like the popen function) on Cloudplex through the Script Snap or a Custom Snap. While external process creation on Groundplex is possible. You can request support@snaplogic.com to disable this if required.

Snap Type

The Script Snap is a write-type Snap.

Support for Ultra Pipelines

Works in Ultra Pipelines if you pass the original document to the write() method for the output view. For example, in the JavaScript template, the body of the loop is per the following: 

Note the following two arguments in the output.write() method:

  • The first argument is the input document—doc.

  • The second argument is the data for the output document—wrapper.

Both the arguments are required so that the lineage of the output document can be tied to the input document. This is important for an Ultra pipeline responding to web requests. The initial request becomes an input document to the first Snap in the SnapLogic pipeline, eventually resulting in an output document from the last Snap in the pipeline. The pipeline must maintain the lineage of each document so that each response can be correlated to the request that generated it.

Limitations and Known Issues

For JavaScript, objects written to the output view should be composed of serializable Java types. Some downstream Snaps, such as the Copy Snap, require this. To write out a map to the output view in a JavaScript, use a Java Map implementation, such as HashMap or LinkedHashMap, per the following:

Breaking Changes

The following breaking changes apply to the pipelines using the Script Snap (or the deprecated Execute Script Snap) with the Python engine.

To implement Python in the Script Snap, we use Jython. We have upgraded the Jython engine from version 2.7-b3 (a beta version from 2014) to version 2.7.2 (March 2020). The following are the resultant issues and workarounds:

  • An open bug in 2.7 introduced a backward-incompatible change in the SnapLogic platform wherein the Jython engine automatically converts BigInteger values to primitive long values. This impacts all your scripts that perform numeric manipulation of integer values from documents (SnapLogic uses the BigInteger type to represent integers in documents). Your pipelines and Snaps with the Script Snap (or the deprecated Execute Script Snap) that use numeric manipulation scripts with integer or BigInteger data type may fail during execution. We recommend you prospectively replace integer or BigInteger values with long values.

    Example:
    sum = a.intValue() + b.intValue()
    Here, a and b are of BigInteger type that now fail as Jython 2.7.2 automatically and transparently calls longValue() on any BigInteger value it encounters. So a and b would need to use the long and not BigInteger type.

    The known fix is to rewrite the above calculation as sum = a + b by removing occurrences of .intValue() or .longValue() from your Python scripts. 

  • Before the 4.22 release (August 2020), when using the Script Snap with the Scripting language option selected as Python, requesting a key that did not exist in a dictionary (for example, my_dict['missing_key']) would return None. Starting from the 4.22 release, the same request returns a KeyError exception. If you need to continue returning None, use the .get(key) method instead (for example, my_dict.get['missing_key']).

  • - zlib.compress():
 The zlib library compresses the JSON files retrieved from the SnapLogic APIs and backs-up Pipelines and accounts to a database. The following Python code, when trying to compress displays an ascii … ordinal not in range(128) error.
    Original code: in_doc["json"] = zlib.compress(in_doc["json"])
    Fix: in_doc["json"] = zlib.compress(in_doc["json"].encode("utf-8"))

  • {dictionary}.values().toArray()[i]:
Before the 4.22 release (August 2020), to subscript a {dictionary}.values() method, you had to append the toArray() method to values(); else, you would see the Failure: ‘java.util.LinkedHashMap$LinkedValues’ object is unsubscriptable error. After the 4.22 release, toArray() returns Failure: ‘list’ object has no attribute ‘toArray’. However, the requirement for toArray() is no longer necessary for the subscript.
    Original code: sLine = data.values().toArray()[0]
    Fix: sLine = data.values()[0]

Snap Views

Type

Format

Number of Views

Examples of Upstream and Downstream Snaps

Description

Input 

Document

 

  • Min: 0

  • Max: 1

  • Mapper

This Snap has at most one document input view.

Output

Document

 

  • Min: 0

  • Max: 1

  • Mapper

  • Copy

This Snap has at most one document output view. 

Error

Error handling is a generic way to handle errors without losing data or failing the Snap execution. You can handle the errors that the Snap might encounter when running the pipeline by choosing one of the following options from the When errors occur list under the Views tab:

  • Stop pipeline Execution: Stops the current pipeline execution if the Snap encounters an error.

  • Discard Error Data and Continue: Ignores the error, discards that record, and continues with the remaining records.

  • Route Error Data to Error View: Routes the error data to an error view without stopping the Snap execution.

Learn more about Error handling in Pipelines.

Snap Settings

  • Asterisk ( * ): Indicates a mandatory field.

  • Suggestion icon ((blue star)): Indicates a list that is dynamically populated based on the configuration.

  • Expression icon ((blue star) ): Indicates the value is an expression (if enabled) or a static value (if disabled). Learn more about Using Expressions in SnapLogic.

  • Add icon ( (blue star) ): Indicates that you can add fields to the field set.

  • Remove icon ( (blue star)): Indicates that you can remove fields from the field set.

  • Upload icon ((blue star) ): Indicates that you can upload files.

Field Name

Field Type

Description

Label*

Default Value: Script
Example: Script

String

Specify a unique name for the Snap. You can modify this to be more specific, especially if you have more than one of the same Snap in your pipeline.

Scripting Language*

Default valueJavascript
ExampleRuby

Dropdown list

Choose a language for the script. The available options are:

  • Javascript

  • Python

  • Ruby

Script file

Default value: None
Example: transform.py

String/Expression

Specify or select a script file that implements the ScriptHook interface. This field can be used if the script file is present in the SLDB. Click on the Upload (blue star) icon to upload the required script file from the SLDB. 

This field accepts pipeline parameters as well as upstream parameters provided the script file is present in the SLDB. 

Edit Script

Default Value: A skeleton for the chosen scripting language.  You can click the Generate Template link to regenerate the skeleton.

Button

Click the Edit Script button to edit a script within the Snap instead of through an external file. From this page, you can export the script to a file in a project, import a script, or generate a template for the selected Scripting Language.

  • Once you select the language of your choice, click the Edit Script button to open the script editor. 

  • By default, the editor is populated with a basic script you can modify.

  • The basic script reads an input document, wraps it in a map, and writes the wrapper to the output view. If a script file is present in the SLDB, you can upload it to the Snap using the Script file property; this property also accepts pipeline parameters and upstream parameters. 

Snap execution

Default Value: Execute only
Example: Validate & Execute

Dropdown list

Select one of the three modes in which the Snap executes. Available options are:

  • Validate & Execute: Performs limited execution of the Snap, and generates a data preview during Pipeline validation. Subsequently, performs full execution of the Snap (unlimited records) during Pipeline runtime.
  • Execute only: Performs full execution of the Snap during Pipeline execution without generating preview data.
  • Disabled: Disables the Snap and all Snaps that are downstream from it.

ScriptHook Interface

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

Importing Third-Party Libraries

While SnapLogic does not support importing third-party libraries directly using the Script Snap, you can add their package/JAR files in a directory in your Groundplex nodes and then import them using this Snap. For example, consider that you have added the JAR file, mongo-java-driver-3.12.7.jar, in the directory /opt/snaplogic/ext_jar/. For your Python scripts to be able to use this library, create a file named .jython in the home directory of the user running the JCC process. The .jython file should specify a value for the python.path, as follows:

python.path=/opt/snaplogic/ext_jar/mongo-java-driver-3.12.7.jar

You can find the user’s home directory (user running the jcc) in the jcc filename “jcc_output.log" when you search with user.home. If you have multiple jar files, you can add all the paths in the same .jython file separated by colon, as shown below:

python.path=jar1_path:jar2_path:jar3_path

Here’s an example of Python script that imports and uses code from this library. Use the cleanup method to ensure that the mongoClient object is appropriately closed.

from com.snaplogic.scripting.language import ScriptHook
from com.mongodb.client import MongoClients

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):
        try:
            self.mongoClient = MongoClients.create("mongodb://localhost:27017/?readPreference=primary&ssl=false")
            for d in self.mongoClient.listDatabases():
                self.output.write(d)
        except Exception as e:
            errDoc = {
                'error' : str(e.args)
            }
            self.error.write(errDoc)

    def cleanup(self):
        self.mongoClient.close()

hook = TransformScript(input, output, error, log)
  • 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. Learn more about using the .jython file: Jython Registry.

  • The python.path variable is Jython's version of CPython’s PYTHONPATH variable. Refer to the official Python documentation for more about the PYTHONPATH.

  • If you are using multiple Groundplex nodes, you must add the package/JAR files in each node.

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

Additional Information

The document data can be converted to and from the JSON data interchange language. By convention, the root of every document is conceptually a JSON object—a collection of name-value pairs, where each name is a string, and each value is an object, an array, a string, a number, a boolean, or a null. Every modern programming language has a corresponding type for this concept:

Script

Type

Java

Map

Python

Dictionary 

Ruby

Hash

JavaScript

Object 

When writing a script for the Script Snap, each input document is an object that implements the Java Map interface and can be accessed as an instance of the scripting language’s native object class, such as a Python dictionary.

To write an output document, your script must create a new object. In Python or Ruby, you can create an instance of the required language’s native object type, a Python dictionary, or a Ruby hash. The values you add to these objects must be one of the JSON-compatible types, including objects, arrays, strings, numbers, and booleans. You can use the corresponding array or list type of the language for an array. Objects written to the output view should be of Java types. Some downstream Snaps require this, for example, the Join Snap. To write a Python map to the output view in a Python script, convert the map to a Java HashMap.

General Instructions for all Scripting Languages

The script author should declare a global variable named 'hook' (note that this variable name is case-sensitive). The Script engine makes the following four global variables available to the script as defined in the Script#ScriptHook Interface section:

  • The variable input is of type ScriptHook.Input

  • The variable output is of type ScriptHook.Output

  • The variable error is of type ScriptHook.Error

  • The variable log is of type org.slf4j.Logger

Type defined in the schema maps to the Java class per the following:

 Data Type

Java class

 NUMBER  

 java.math.BigDecimal

 INTEGER

 java.math.BigInteger 

 STRING

 java.lang.String

 DATETIME

 org.joda.time. DateTime  

 LOCALDATETIME

 org.joda.time. LocalDateTime 

 BOOLEAN

 java.lang.Boolean 

 DATE

 org.joda.time.LocalDate 

 TIME

 org.joda.time.LocalTime

 BINARY

 java.lang.Byte 

 TABLE

 java.util.List 

 ANY

 java.lang.Object 

 COMPOSITE

 java.util.Map 


Example Scripts

JavaScript

Python

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


Script Snap Configuration Using Python, JS Script, and Ruby Script 

The following pipeline demonstrates how the Script Snap executes in all three supported languages. This pipeline uses a simple JSON file with First Name, Last Name, and Birthday.

 

The following is a snapshot of the input for the Script Snap:

Python Script

Script Snap uses the Jython engine to execute the scripts written in Python. 

Java Script

The Script Snap uses the Nashorn engine to execute the scripts written in JavaScript.

Ruby Script

Script Snap uses JRuby engine to execute the scripts written in Ruby.

A sample preview output of the successful execution for all the three Snaps is shown below:

 Output from the Python script

 

 Output from the JS script
 Output from the Ruby script

  

The exported pipeline is available in the Script#Downloads section below.

Script Snap Execution Using Pipeline Parameters

The following example demonstrates the execution of the Script Snap using the pipeline parameters; the script file in the SLDB is passed as a Pipeline parameter. The pipeline demonstrated above is modified to accept pipeline parameters by configuring the Script file property. For the scripts to be passed as a pipeline parameter, the script file should be present in the project folder in SnapLogic. Confirm that the script files are present in the Files section inside the Manager; if not, upload them by clicking on the '+' icon.

In this example, there are three files, one for each type of scripting language:

Below is a snapshot of the pipeline's properties and configured pipeline parameters.

 

The individual Script Snaps are configured as shown below:

As in the example above, this pipeline produces the same output on execution. The exported pipeline and sample script files used are available as a zip file in the Downloads section below.

Downloads

Important steps to successfully reuse Pipelines

  1. Download and import the Pipeline into SnapLogic.
  2. Configure Snap accounts as applicable.
  3. Provide Pipeline parameters as applicable.

  File Modified
You are not logged in. Any changes you make will be marked as anonymous. You may want to Log In if you already have an account.
No files shared here yet.
  • Drag and drop to upload or browse for files
  •  

    Related Content:

    Snap Pack History

     Click to view/expand
    ReleaseSnap Pack VersionDateType Updates

    May 2024

    main26341

     

    Stable

    Updated and certified against the current SnapLogic Platform release.

    February 2024main25112 StableUpdated and certified against the current SnapLogic Platform release.
    November 2023main23721 StableUpdated and certified against the current SnapLogic Platform release.

    August 2023

    main22460

     

    Stable

    Updated and certified against the current SnapLogic Platform release.

    May 2023main21015 StableUpgraded with the latest SnapLogic Platform release.
    February 2023main19844 StableUpgraded with the latest SnapLogic Platform release.
    November 2022main18944 StableUpgraded with the latest SnapLogic Platform release.
    August 2022main17386 StableUpgraded with the latest SnapLogic Platform release.

    4.29

    main15993

      

    Stable

    Upgraded with the latest SnapLogic Platform release.

    4.28main14627
     
    StableUpgraded with the latest SnapLogic Platform release.

    4.27

    main12833

     

    Stable

    Upgraded with the latest SnapLogic Platform release.
    4.26main11181
     
    StableUpgraded with the latest SnapLogic Platform release.
    4.25main9554
     
    StableUpgraded with the latest SnapLogic Platform release.
    4.24main8556
     
    StableUpgraded with the latest SnapLogic Platform release.
    4.23 Patch423patches7671
     
    Latest

    Fixes an issue with the PySpark Snap by removing the dependency on the json-path library, thus avoiding a conflict between the external library version and the SnapLogic json-path.jar.

    4.23main7430
     
    Stable

    Upgraded with the latest SnapLogic Platform release.

    4.22main6403
     
    Latest

    Upgraded the Jython engine from version 2.7-b3 (a beta version from 2014) to the current version, 2.7.2 (March, 2020). See the breaking changes note for Script Snap and the deprecated Execute Script Snap in the Limitations and Known Issues section for potential impacts of this upgrade.   

    4.21snapsmrc542-Stable

    Adds a new Cleanup method in the ScriptHook interface associated with the Script Snap. This method enables the Script Snap to automatically execute a clean-up once the configured script completes executing.

    4.20snapsmrc535-StableUpgraded with the latest SnapLogic Platform release.
    4.19snaprsmrc528-StableUpgraded with the latest SnapLogic Platform release.
    4.18snapsmrc523-Latest

    Enhanced the PySpark Snap to work in Kerberized Hadoop clusters with the addition of a Kerberos account.

    4.17 Patch ALL7402-Latest

    Pushed automatic rebuild of the latest version of each Snap Pack to SnapLogic UAT and Elastic servers.

    4.17snapsmrc515-Stable

    Added the Snap Execution field to all Standard-mode Snaps. In some Snaps, this field replaces the existing Execute during preview check box.

    4.16 snapsmrc508-StableUpgraded with the latest SnapLogic Platform release.
    4.15snapsmrc500-StableUpgraded with the latest SnapLogic Platform release.

    4.14

    snapsmrc490

    -StableUpgraded with the latest SnapLogic Platform release.
    4.13snapsmrc486-StableUpgraded with the latest SnapLogic Platform release.

    4.12

    snapsmrc480

    -Stable

    Updated the PySpark Snap to enable users to stop a PySpark job in progress by pressing the STOP button.

    4.11

    snapsmrc465

    -Stable

    Added a new Snap, the PySpark Snap which is supported on the Groundplex on edge node and Hadooplex node.

    4.10

    snapsmrc414

    -StableUpgraded with the latest SnapLogic Platform release.

    4.9

    snapsmrc405

    -StableUpgraded with the latest SnapLogic Platform release.

    4.8

    snapsmrc398

    -StableUpgraded with the latest SnapLogic Platform release.

    4.7

    snapsmrc382

    -StableUpgraded with the latest SnapLogic Platform release.

    4.6.0

    snapsmrc344

    -StableUpgraded with the latest SnapLogic Platform release.

    4.4.1

    --Latest

    Updated default generated template to ensure compatibility with both JDK 7 and 8 JSR-223 Script Engines.

    March 2015

    --Stable

    Script Snap: Generate Template a link has been added within the Edit Script page to provide a template for each of the supported languages.

    January 2015

    --Stable

    Script Snap: Optional Execute during preview property added.

    December 20, 2014

    --Stable

    Documentation enhancement: updated script samples with a sample pipeline

    May 2014

    --Stable

    Script Snap was introduced in this release.

    Initial Release (June 2013)

    --Stable

    Execute Script introduced in this release.

     

    • No labels