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> 此节点的 _DatasourceBuilder。 默认值: None
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> 此节点的 _ModuleBuilder 默认值: None
module_wiring	Dict[str, object] 节点的输入/输出与模块输入/输出之间的映射。 包含两个键：输入和输出；每个键都映射到一个字典，其键为模块的输入/输出名称，值为节点的端口。 默认值: None
runconfig	str 将用于 python_script_step 的 runconfig 默认值: None
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 设置为 True 以验证是否可以在不对 Azure ML 服务进行任何外部 API 调用的情况下生成图。 默认值: None
regenerate_outputs	bool 设置为 True 以强制新的运行（禁止模块/数据源重用）。 默认值: False

返回

类型	说明
dict	{node_id, (resource_id, is_new_resource)} 的字典

generate_yaml

生成图的 yaml 表示形式。

generate_yaml()

返回

类型	说明
dict	返回 yaml 字典

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 指示在一个步骤失败时是否让试验继续执行。 如果为 True，则仅对失败步骤的输出具有依赖关系的步骤将继续执行。 默认值: False
regenerate_outputs	bool 设置为 True 以强制新的运行（禁止模块/数据源重用） 默认值: False
parent_run_id	为此管道运行的父运行设置的可选运行 ID，该 ID 将在 RunHistory 中反映出来。 父运行必须属于此管道所要提交到的同一试验。 默认值: None
kwargs 必需	dict 自定义关键字参数，保留用于将来的开发。

返回

类型	说明
PipelineRun	PipelineRun。

validate

验证图。 返回错误列表。

validate()

返回

类型	说明
list	列出错误。

属性

datasource_nodes

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

返回

类型	说明
list	Node 的列表

edges

获取边缘的迭代器。

返回

类型	说明
list	Edge 的列表

module_nodes

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

返回

类型	说明
list	Node 的列表

node_dict

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

返回

类型	说明
dict	{node Id, Node} 的字典

node_name_dict

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

返回

类型	说明
dict	{node name, Node} 的字典

nodes

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

返回

类型	说明
list	Node 的列表

params

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

返回

类型	说明
dict	{param name, param value} 的字典