Use the Python Instance operator to specify and configure the name and features of a constrained local instance execution environment for a set of Python operators. It is the Python operator itself that executes Python code. This Python Instance operator's only purpose is to define an optional local execution environment for one or more Python operators.
Use the following steps:
-
Place a Python Instance operator on the EventFlow canvas, and give the operator a name, such as
ThisInstance. -
In the Properties view for the Python Instance operator, select
Localin the Instance Type control. -
Specify the full path to your preferred Python version in the Executable control.
To avoid typing the same path in several Python Instance operators, you can optionally use an operator parameter to specify the Python path. In this case, define the operator parameter in a HOCON configuration file of type
com.tibco.ep.streambase.configuration.sbengine. Save this file in the project'ssrc/main/configurationsfolder. -
Next, in the Properties view for any actual Python operator:
-
Select
Localin the Instance Type control. -
Specify the name you chose in step 1 in the Local Instance Id control.
-
By default, Python operators execute in the global execution environment of the containing EventFlow module.
However, it is possible to use EventFlow concurrency features to run multiple copies of a single module that contains Python operators. In this case, you can use a Python Instance operator to define and name a local execution environment for the Python operators in that concurrent module. In this way, the execution of Python in one concurrent instance of that module does not interfere with other instances.
You can also configure a Python Instance operator with a control port that lets you enable and disable at runtime the execution of Python operators configured to use that Python instance.
This section describes the properties you can set for the Python Instance operator, using the various tabs of the Properties view in StreamBase Studio.
Name: Use this required field to specify or change the name of this instance of this component, which must be unique in the current EventFlow module. The name must contain only alphabetic characters, numbers, and underscores, and no hyphens or other special characters. The first character must be alphabetic or an underscore.
Operator: A read-only field that shows the formal name of the operator.
Class name: Shows the fully qualified class name that implements the functionality of this operator. If you need to reference this class name elsewhere in your application, you can right-click this field and select Copy from the context menu to place the full class name in the system clipboard.
Start options: This field provides a link to the Cluster Aware tab, where you configure the conditions under which this operator starts.
Enable Error Output Port: Select this check box to add an Error Port to this component. In the EventFlow canvas, the Error Port shows as a red output port, always the last port for the component. See Using Error Ports to learn about Error Ports.
Description: Optionally enter text to briefly describe the component's purpose and function. In the EventFlow Editor canvas, you can see the description by pressing Ctrl while the component's tooltip is displayed.
| Property | Type | Description |
|---|---|---|
| Python Configuration | Edit Button | Shortcut to the StreamBase Configuration File Editor, used for adapter configuration or converting an existing application's adapter-configurations.xml file to HOCON format.
|
| Instance Type | radio button |
Select Local to define a constrained local Python execution environment named by the EventFlow canvas name of this operator. Select Global to disable this Python Instance's operator's local execution environment. |
| Global Instance ID | drop-down list | Only active when Instance Type specifies Global. In this case, the global Python execution environment is named and defined in this adapter's configuration file, src/main/resources/adapter-configurations.xml. Use the drop-down control to select the name of a global instance defined in configuration.
|
| executable | string | Specifies the full path to the Python executable to use for all Python operators in the local execution environment defined
by this Python Instance operator. If not specified, the operator invokes the command python, which is assumed to be on the PATH. The path can be specified in ${param} form as the name of an operator parameter that specifies the Python path.
Be careful about specifying a different Python executable in this field than the executable you specify in the configuration file for the global environment — unless you explicitly intend to use a different Python version for the global and local cases. For the same reason, be careful about leaving this field blank, which then specifies the first command named python on the PATH. See Python Versions Supported for example paths. |
| Working Directory | text | Applies when is to specify the working directory for the launched Python processes in this local execution environment. If not specified, processes are started in the same directory as the parent StreamBase process. |
| Use Temp File | check box | Applies when is to indicate that the Python operator's integration layer should create a temporary file with Python code wrapping the interactions
with StreamBase instead of pushing it through standard input. The default standard input method works for most Python interpreters
and is the default.
NoteYou must set this property to |
| Capture Output | check box | When Instance Type is Local, modifies the stdout and stderr behavior. By default, both are chained to the parent process's stdout and stderr. When running tests that include output, you can set this flag to capture the output. |
| Enable Control Port | check box | Enables the control port to allow commands to be sent to this operator. See Control Port below. |
| Log Level | INFO | Controls the level of verbosity the adapter uses to issue informational traces to the console. This setting is independent of the containing application's overall log level. Available values, in increasing order of verbosity, are: OFF, ERROR, WARN, INFO, DEBUG, TRACE. |
Use this tab to specify arguments to be passed to the Python interpreter (not the Python script) to be invoked for all Python operators in the local execution environment defined by this Instance operator.
The usual use for this tab it to pass -u, which forces Python to use unbuffered stdin, stdout, and stderr streams. Consult the following references for information
on Python launch parameters:
Use this tab to specify environment variables to be passed before launching the Python interpreter by all Python operators in the local execution environment defined by this Instance operator. Environment variables specified here can potentially override variables in the platform's environment.
Use the settings in this tab to allow this operator or adapter to start and stop based on conditions that occur at runtime in a cluster with more than one node. During initial development of the fragment that contains this operator or adapter, and for maximum compatibility with TIBCO Streaming releases before 10.5.0, leave the Cluster start policy control in its default setting, Start with module.
Cluster awareness is an advanced topic that requires an understanding of StreamBase Runtime architecture features, including clusters, quorums, availability zones, and partitions. See Cluster Awareness Tab Settings on the Using Cluster Awareness page for instructions on configuring this tab.
If you enable the control port, it accepts a tuple with any structure, but one string field must be named command. The command strings accepted on this control port are:
-
start — Enables the local Python execution environment defined by this Python Instance operator.
-
stop — Disables this operator's local Python execution environment. Any Python operators configured to use this operator's instance return an error instead of processing input tuples while this Python Instance operator is disabled.
Any unrecognized fields in the control port's input tuple are ignored.