com.github.kfcfans.powerjob.worker.core.processor.built

类 ScriptProcessor

java.lang.Object

com.github.kfcfans.powerjob.worker.core.processor.built.ScriptProcessor

所有已实现的接口:

BasicProcessor

直接已知子类:

PythonProcessor, ShellProcessor

public abstract class ScriptProcessor
extends Object
implements BasicProcessor

脚本处理器

从以下版本开始:

2020/4/16

作者:

tjq

字段概要

字段

限定符和类型	字段和说明
protected Long	instanceId

构造器概要

构造器

构造器和说明
ScriptProcessor(Long instanceId, String processorInfo, long timeout)

方法概要

限定符和类型	方法和说明
protected abstract String	fetchRunCommand() 获取运行命令（eg，shell返回 /bin/sh）
protected abstract String	genScriptName() 生成脚本名称
ProcessResult	process(TaskContext context) 核心处理逻辑

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

instanceId

protected final Long instanceId

构造器详细资料

ScriptProcessor

public ScriptProcessor(Long instanceId,
                       String processorInfo,
                       long timeout)
                throws Exception

抛出:

Exception

方法详细资料

process

public ProcessResult process(TaskContext context)
                      throws Exception

从接口复制的说明: BasicProcessor

核心处理逻辑

指定者:

process 在接口中 BasicProcessor

参数:

context - 任务上下文，可通过 jobParams 和 instanceParams 分别获取控制台参数和OpenAPI传递的任务实例参数

返回:

处理结果，msg有长度限制，超长会被裁剪，不允许返回 null

抛出:

Exception - 异常，允许抛出异常，但不推荐，最好由业务开发者自己处理

genScriptName

protected abstract String genScriptName()

生成脚本名称

返回:

文件名称

fetchRunCommand

protected abstract String fetchRunCommand()

获取运行命令（eg，shell返回 /bin/sh）

返回:

执行脚本的命令