HiveNetPipeline.embed_router module

管道通用路由插件模块

class HiveNetPipeline.embed_router.GoToNode

基类：HiveNetPipeline.pipeline.PipelineRouter

跳转到指定节点

classmethod get_next(output, context: dict, pipeline_obj, run_id: str, **kwargs)

获取路由下一节点

参数

• output (object) – 上一个节点的输出结果

• context (dict) – 上下文字典

• pipeline_obj (Pipeline) – 管道对象

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

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

返回

下一节点的配置id, 如果是最后的节点, 返回None

返回类型

str

classmethod router_name() → str

路由器名称, 唯一标识路由器

返回

当前路由器名称

返回类型

str

class HiveNetPipeline.embed_router.IfGotoNode

基类：HiveNetPipeline.pipeline.PipelineRouter

根据指定条件跳转到对应节点

classmethod get_next(output, context: dict, pipeline_obj, run_id: str, **kwargs)

获取路由下一节点

参数

• output (object) – 上一个节点的输出结果

• context (dict) – 上下文字典

• pipeline_obj (Pipeline) – 管道对象

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

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

返回

下一节点的配置id, 如果是最后的节点, 返回None

返回类型

str

classmethod router_name() → str

路由器名称, 唯一标识路由器

返回

当前路由器名称

返回类型

str