Graph 类

用于定义管道运行图的类。

初始化图形。

继承

builtins.object

Graph

构造函数

Graph(name, context)

参数

name

str

必需

图的名称。

context

<xref:azureml.pipeline.core._GraphContext>

必需

当前图上下文。

name

str

必需

图的名称。

context

<xref:azureml.pipeline.core._GraphContext>

必需

当前图上下文。

方法

add_datasource_node	将数据源节点添加到图。
add_module_node	将模块节点添加到图。
connect	连接两个端口并创建边缘。
delete_node	从图中删除节点。
finalize	最终确定图中节点的资源。
generate_yaml	生成图的 yaml 表示形式。
get_node	按 ID 获取节点。
sequence	将节点列表配置为按照列表中第一个节点之后的顺序运行。
submit	提交图以在云中运行。
validate	验证图。 返回错误列表。

add_datasource_node

将数据源节点添加到图。

add_datasource_node(name, datasource=None, datasource_builder=None, datapath_param_name=None)

参数

name

str

必需

节点的名称。

datasource

DataSource

默认值: None

此节点的数据源。

datasource_builder

<xref:azureml.pipeline.core._DatasourceBuilder>

默认值: None

此节点的 _DatasourceBuilder。

datapath_param_name

str

默认值: None

数据路径参数名称。

返回

节点

返回类型

Node

add_module_node

将模块节点添加到图。

add_module_node(name, input_bindings, output_bindings=None, param_bindings=None, module=None, module_builder=None, module_wiring=None, runconfig=None, cloud_settings=None)

参数

name

str

必需

节点的名称

input_bindings

list

必需

输入端口绑定的列表。

output_bindings

list

默认值: None

输出端口绑定的列表。

param_bindings

dict

默认值: None

参数分配的名称/值对字典。

module

Module

默认值: None

此节点的模块

module_builder

<xref:azureml.pipeline.core._ModuleBuilder>

默认值: None

此节点的 _ModuleBuilder

module_wiring

Dict[str, object]

默认值: None

节点的输入/输出与模块输入/输出之间的映射。 包含两个键：输入和输出；每个键都映射到一个字典，其键为模块的输入/输出名称，值为节点的端口。

runconfig

str

默认值: None

将用于 python_script_step 的 runconfig

cloud_settings

<xref:azureml.pipeline.core._restclients.aeva.models.CloudSettings>

默认值: None

用于云的设置

返回

节点

返回类型

Node

connect

连接两个端口并创建边缘。

connect(source_port, dest_port)

参数

source_port

OutputPort

必需

用作连接源的节点的输出端口

dest_port

InputPort

必需

来自作为连接目标的节点的输入端口

返回

边缘

返回类型

Edge

delete_node

从图中删除节点。

delete_node(node_id)

参数

node_id

str

必需

节点 ID

finalize

最终确定图中节点的资源。

finalize(dry_run=None, regenerate_outputs=False)

参数

dry_run

bool

默认值: None

设置为 True 以验证是否可以在不对 Azure ML 服务进行任何外部 API 调用的情况下生成图。

regenerate_outputs

bool

默认值: False

设置为 True 以强制新的运行（禁止模块/数据源重用）。

返回

{node_id, (resource_id, is_new_resource)} 的字典

返回类型

dict

generate_yaml

生成图的 yaml 表示形式。

generate_yaml()

返回

返回 yaml 字典

返回类型

dict

get_node

按 ID 获取节点。

get_node(node_id)

参数

node_id

str

必需

节点 ID。

返回

节点。

返回类型

Node

sequence

将节点列表配置为按照列表中第一个节点之后的顺序运行。

sequence(nodes)

参数

nodes

list

必需

节点的列表。

submit

提交图以在云中运行。

submit(pipeline_parameters=None, continue_on_step_failure=False, regenerate_outputs=False, parent_run_id=None, **kwargs)

参数

pipeline_parameters

dict

默认值: None

管道执行的参数。 可选。

continue_on_step_failure

bool

默认值: False

指示在一个步骤失败时是否让试验继续执行。 如果为 True，则仅对失败步骤的输出具有依赖关系的步骤将继续执行。

regenerate_outputs

bool

默认值: False

设置为 True 以强制新的运行（禁止模块/数据源重用）

parent_run_id

默认值: None

为此管道运行的父运行设置的可选运行 ID，该 ID 将在 RunHistory 中反映出来。 父运行必须属于此管道所要提交到的同一试验。

kwargs

dict

必需

自定义关键字参数，保留用于将来的开发。

返回

PipelineRun。

返回类型

PipelineRun

validate

验证图。 返回错误列表。

validate()

返回

列出错误。

返回类型

list

属性

datasource_nodes

获取包含所有数据源节点的列表。

返回

Node 的列表

返回类型

list

edges

获取边缘的迭代器。

返回

Edge 的列表

返回类型

list

module_nodes

获取包含所有模块节点的列表。

返回

Node 的列表

返回类型

list

node_dict

获取包含所有节点的字典。

返回

{node Id, Node} 的字典

返回类型

dict

node_name_dict

获取包含按名称编制索引的所有节点的字典。

返回

{node name, Node} 的字典

返回类型

dict

nodes

获取包含所有节点的列表。

返回

Node 的列表

返回类型

list

params

获取包含所有图参数的字典。 值是文本类型，或 JSON 字符串形式的数据引用。

返回

{param name, param value} 的字典

返回类型

dict