您可以使用kfp.dsl.EXECUTION_ID_PLACEHOLDER和kfp.dsl.RUN_ID_PLACEHOLDER作为组件的参数。在运行时，它们将被替换为实际值。

我试着用Python's DSL来做这件事，但现在似乎不可能。
我发现的唯一选择是使用他们在这个示例代码中使用的方法，基本上就是声明一个包含{{workflow.uid}}的字符串，在执行时它将被替换为实际值。
您也可以这样做以获取pod名称，它将是{{pod.name}}。

由于Kubeflow管道依赖于Argo，因此您可以使用Argo变量来获得您想要的内容。
例如，

@func_to_container_op
def dummy(run_id, run_name) -> str:
    return run_id, run_name

@dsl.pipeline(
    name='test_pipeline',
)
def test_pipeline():
  dummy('{{workflow.labels.pipeline/runid}}', '{{workflow.annotations.pipelines.kubeflow.org/run_name}}')

您会发现占位符将替换为正确的run_id和run_name。
更多argo变量：https://github.com/argoproj/argo-workflows/blob/master/docs/variables.md
要了解kubeflow管道运行中的标签和注解中记录了什么，只需从k8s中获取相应的工作流。

kubectl get workflow/XXX -oyaml

create_run_from_pipeline_func，它返回RunPipelineResult，并具有run_id attribute

client = kfp.Client(host)
result = client.create_run_from_pipeline_func(…) 
result.run_id

组件的容器应该有一个名为HOSTNAME的环境变量，该变量设置为唯一的pod名称，您可以从中派生所有必要的元数据。

对于V1：
看起来kfp.dsl.EXECUTION_ID_PLACEHOLDER（组件运行id）和kfp.dsl.RUN_ID_PLACEHOLDER（管道运行id）将完成您所要求的。
源
对于V2：
分别为kfp.v2.dsl.PIPELINE_JOB_ID_PLACEHOLDER和kfp.v2.dsl.PIPELINE_TASK_ID_PLACEHOLDER。
source