HiveNetPipeline.embed_predealer module

管道通用预处理器插件模块

class HiveNetPipeline.embed_predealer.ConditionPredealer

基类：PipelinePredealer

条件预处理器

classmethod pre_deal(input_data, context: dict, pipeline_obj, run_id: str, **kwargs)

执行预处理

参数

• input_data (object) – 处理器输入数据值, 除第一个处理器外, 该信息为上一个处理器的输出值

• context (dict) – 传递上下文, 该字典信息将在整个管道处理过程中一直向下传递, 可以在处理器中改变该上下文信息

• pipeline_obj (Pipeline) –

  管道对象, 作用如下:

  1、更新执行进度

  2、输出执行日志

  3、异步执行的情况主动通知继续执行管道处理

• run_id (str) – 当前管道的运行id

• 传入的预处理扩展参数 (-) –

返回

是否继续执行该节点, True - 继续执行该节点, False - 跳过该节点直接执行下一个节点

返回类型

bool

classmethod predealer_name() → str

预处理器名称, 唯一标识处理器

返回

当前处理器名称

返回类型

str