python

type PythonNode ¶

type PythonNode struct {
	Config PythonNodeConfiguration
	// contains filtered or unexported fields
}

PythonNode is an action component that executes Python scripts. It spawns a python3 subprocess for each message, passes input via stdin JSON, and reads the result from stdout JSON.

JSON rule chain DSL example:

{
  "id": "s1",
  "type": "x/python",
  "name": "Python处理",
  "configuration": {
    "script": "import json\ndata = json.loads(msg) if isinstance(msg, str) else msg\ndata['processed'] = True\nreturn json.dumps(data), metadata, msgType",
    "pythonPath": "python3",
    "timeout": "5s",
    "maxRunning": 10
  }
}

func (x *PythonNode) Desc() string

func (x *PythonNode) Destroy()

func (x *PythonNode) Init(ruleConfig types.Config, configuration types.Configuration) error

func (x *PythonNode) New() types.Node

func (x *PythonNode) OnMsg(ctx types.RuleContext, msg types.RuleMsg)

func (x *PythonNode) Type() string

type PythonNodeConfiguration ¶

type PythonNodeConfiguration struct {
	Script     string `json:"script" label:"Script" desc:"Python script content or .py file path" required:"true"`
	PythonPath string `json:"pythonPath" label:"Python Path" desc:"Python interpreter path, uses system PATH by default"`
	Timeout    string `json:"timeout" label:"Timeout" desc:"Script execution timeout, e.g. 10s, 1m"`
	MaxRunning int    `json:"maxRunning" label:"Max Running" desc:"Max concurrent executions, default 1"`
}

PythonNodeConfiguration node configuration