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

安排管道运行

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

可以自动启动以下管道操作： 

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

向 Amazon 安排管道 EventBridge

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

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

先决条件

使用 EventBridge控制台创建 EventBridge 规则

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

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

使用创建 EventBridge 规则 AWS CLI

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

使用 SageMaker Python 安排管道 SDK

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

所需的权限

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

{
    "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 开始按指定的时间或速率调用目标管道。必须指定具有正确权限的角色才能将触发器附加到父管道。如果您不提供默认角色，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_triggersAPI。以下代码段演示了如何删除触发器。

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