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	连接两个端口并创建 Edge。
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 Datapath 参数名称。默认值: 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

连接两个端口并创建 Edge。

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} 的字典