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

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

安排管道运行

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

可自动启动以下 Pipelines 操作： 

有关安排 SageMaker AI 任务的更多信息，请参阅使用 A mazon EventBridge 自动化 SageMaker AI。

向 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 构造函数，可以将管道调度为运行一次或按预定时间间隔运行。管道计划必须是 at、rate 或 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_triggers API 传递触发器名称列表来删除触发器。API 传递触发器名称列表，即可删除触发器。下面的代码段演示了如何删除触发器。

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