运行管道

在 KFP 后端执行管道

概述

Kubeflow Pipelines (KFP) 提供多种方式来触发管道运行

  1. KFP 控制面板
  2. KFP SDK 客户端
  3. KFP CLI

运行管道 - KFP 控制面板

运行管道的首选和最简单方法是通过 KFP 控制面板提交。

要提交管道以便立即运行

  1. 编译管道为 IR YAML。

  2. 在控制面板的“Pipelines”选项卡中，选择 + Upload pipeline

    Upload pipeline button

  3. 上传管道 .yaml、.zip 或 .tar.gz 文件，填写上传表单，然后点击 Create。

    Upload pipeline screen

  4. 在“Runs”选项卡中，选择 + Create run

    Create run button

  5. 选择要运行的管道，填写运行表单，然后点击 Start

    Start a run screen

运行管道 - KFP SDK 客户端

您还可以通过 KFP SDK 客户端以编程方式提交管道运行。客户端支持两种提交运行的方式：从 IR YAML 或 从 Python 管道函数。

对于这两种方法，首先实例化一个 kfp.Client()

import kfp

# TIP: you may need to authenticate with the KFP instance
kfp_client = kfp.Client()

要提交用于执行的 IR YAML，请使用 .create_run_from_pipeline_package() 方法

#from kfp import compiler, dsl
#
#@dsl.component
#def add(a: float, b: float) -> float:
#   return a + b
#
#@dsl.pipeline(name="Add two Numbers")
#def add_pipeline(a: float, b: float):
#   add_task = add(a=a, b=b)
#
#compiler.Compiler().compile(
#    add_pipeline, 
#    package_path="./add-pipeline.yaml"
#)

kfp_client.create_run_from_pipeline_package(
    "./add-pipeline.yaml", 
    arguments={
        "a": 1,
        "b": 2,
    }
)

要提交用于执行的 python 管道函数，请使用 .create_run_from_pipeline_func() 便利方法，它将编译和运行提交打包到一个方法中

#from kfp import dsl
#
#@dsl.component
#def add(a: float, b: float) -> float:
#    return a + b
#
#@dsl.pipeline(name="Add two Numbers")
#def add_pipeline(a: float, b: float):
#    add_task = add(a=a, b=b)

kfp_client.create_run_from_pipeline_func(
    add_pipeline,
    arguments={
        "a": 1,
        "b": 2,
    }
)

运行管道 - KFP CLI

通过 kfp run create 命令，您可以从命令行提交管道。

以下是 kfp run create --help 的输出

kfp run create [OPTIONS] [ARGS]...

例如，以下命令将 ./path/to/pipeline.yaml IR YAML 提交到 KFP 后端

kfp run create \
  --experiment-name "my-experiment" \
  --package-file "./path/to/pipeline.yaml"

有关 kfp CLI 的更多信息，请参阅

反馈

此页面是否有帮助？


上次修改时间 2025年3月29日: website: 添加深色主题 (#3981) (4f092f1)