Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异，请参阅 中国的 Amazon Web Services 服务入门 (PDF)。

本文属于机器翻译版本。若本译文内容与英语原文存在差异，则一律以英文原文为准。

安排管道运行

您可以使用 Amazon 安排您的 Amazon SageMaker 模型构建管道的执行 EventBridge。亚马逊支持将亚马逊 SageMaker 模型构建管道作为目标 EventBridge。这样，您就可以根据事件总线中的任何事件启动建模管线的执行。借 EventBridge助，您可以自动执行管道并自动响应诸如训练作业或端点状态更改之类的事件。事件包括上传到您的 Amazon S3 存储桶的新文件、由于偏移而导致的亚马逊 SageMaker 终端节点状态变化以及亚马逊简单通知服务 (SNS) 主题。

可以自动启动 SageMaker 以下 Pipelines 操作： 

有关安排 SageMaker 任务的更多信息，请参阅 SageMaker 使用 Amazon EventBridge 实现自动化。

向 Amazon 安排管道 EventBridge

要使用 Amazon Event CloudWatch s 开始管道执行，您必须创建 EventBridge规则。在为事件创建规则时，您可以指定在 EventBridge 收到与该规则匹配的事件时要采取的目标操作。当事件与规则匹配时， EventBridge 会将该事件发送到指定的目标并启动规则中定义的操作。

以下教程展示了如何 EventBridge 使用 EventBridge控制台或来安排管道执行 Amazon CLI。 

先决条件

使用 EventBridge控制台创建 EventBridge 规则

以下过程说明如何使用 EventBridge 控制台创建 EventBridge 规则。 

您的规则现已生效，可以启动管道执行了。

使用创建 EventBridge 规则 Amazon CLI

以下过程说明如何使用创建 EventBridge 规则 Amazon CLI。

使用 SageMaker Python 软件开发工具包安排管道

以下各节介绍如何使用 SageMaker Python SDK 设置 EventBridge 资源访问权限和创建管道计划。

所需的权限

您需要拥有必要的权限才能使用管道调度器。完成以下步骤来设置您的权限：

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Principal": {
                "Service": [
                    "scheduler.amazonaws.com",
                    "sagemaker.amazonaws.com"
                ]
            },
        "Action": "sts:AssumeRole"
        }
    ]
}

创建管道计划

使用PipelineSchedule构造函数，您可以安排管道运行一次或按预定间隔运行。管道计划必须是atrate、或cron。这组计划类型是EventBridge 计划选项的扩展。有关如何使用该PipelineSchedule类的更多信息，请参阅 sagemaker.workflow.triggers。 PipelineSchedule。以下示例演示如何使用创建每种调度类型PipelineSchedule。

from sagemaker.workflow.triggers import PipelineSchedule

# schedules a pipeline run for 12/13/2023 at time 10:15:20 UTC
my_datetime_schedule = PipelineSchedule(
    name="<schedule-name>", 
    at=datetime(2023, 12, 13, 10, 15, 20)
)

# schedules a pipeline run every 5 minutes
my_rate_schedule = PipelineSchedule(
    name="<schedule-name>", 
    rate=(5, "minutes")
)

# schedules a pipeline run at 10:15am UTC on the last Friday of each month during the years 2022 to 2023
my_cron_schedule = PipelineSchedule(
    name="<schedule-name>", 
    cron="15 10 ? * 6L 2022-2023"
)

将触发器连接到您的管道

要将您的PipelineSchedule连接到您的管道，put_triggers请使用触发器列表对您创建的管道对象调用。如果您收到响应 ARN，则表示您在账户中成功创建了计划，并 EventBridge 开始按指定的时间或速率调用目标管道。必须指定具有正确权限的角色才能将触发器附加到父管道。如果您不提供默认角色， SageMaker Pipelines 会从配置文件中获取用于创建管道的默认角色。

以下示例演示如何将计划附加到管道。

scheduled_pipeline = Pipeline(
    name="<pipeline-name>",
    steps=[...],
    sagemaker_session=<sagemaker-session>,
)
custom_schedule = PipelineSchedule(
    name="<schedule-name>", 
    at=datetime(year=2023, month=12, date=25, hour=10, minute=30, second=30)
)
scheduled_pipeline.put_triggers(triggers=[custom_schedule], role_arn=<role>)

描述当前的触发器

要检索有关您创建的管道触发器的信息，您可以使用触发器名称调用 describe_trigger() API。此命令返回有关已创建的计划表达式的详细信息，例如其开始时间、启用状态和其他有用信息。以下代码段显示了一个调用示例：

scheduled_pipeline.describe_trigger(name="<schedule-name>")

清理触发器资源

在删除管道之前，请清理现有的触发器，以避免账户中出现资源泄漏。在销毁父管道之前，应删除触发器。您可以通过向 delete_triggers API 传递触发器名称列表来删除触发器。以下代码段演示了如何删除触发器。

pipeline.delete_triggers(trigger_names=["<schedule-name>"])