Die vorliegende Übersetzung wurde maschinell erstellt. Im Falle eines Konflikts oder eines Widerspruchs zwischen dieser übersetzten Fassung und der englischen Fassung (einschließlich infolge von Verzögerungen bei der Übersetzung) ist die englische Fassung maßgeblich.

Pipeline-Läufe planen

Sie können Ihre Amazon SageMaker Pipelines-Ausführungen mit Amazon planen. EventBridge Amazon SageMaker Pipelines wird in Amazon EventBridge als Ziel unterstützt. Auf diese Weise können Sie die Ausführung Ihrer Modellerstellungspipeline auf der Grundlage eines beliebigen Ereignisses in Ihrem Event-Bus einleiten. Mit EventBridge können Sie Ihre Pipeline-Ausführungen automatisieren und automatisch auf Ereignisse wie Änderungen des Trainingsjobs oder des Endpunktstatus reagieren. Zu den Ereignissen gehören das Hochladen einer neuen Datei in Ihren Amazon S3 S3-Bucket, eine Änderung des Status Ihres SageMaker Amazon-Endpunkts aufgrund von Drift und Themen zu Amazon Simple Notification Service (SNS).

Die folgenden Pipeline-Aktionen können automatisch initiiert werden: 

Weitere Informationen zur Planung von SageMaker Aufträgen finden Sie unter Automatisieren SageMaker mit Amazon EventBridge.

Planen Sie eine Pipeline mit Amazon EventBridge

Um eine Pipeline-Ausführung mit Amazon CloudWatch Events zu starten, müssen Sie eine EventBridge Regel erstellen. Wenn Sie eine Regel für Ereignisse erstellen, geben Sie eine Zielaktion an, die ausgeführt werden soll, wenn EventBridge ein Ereignis eintrifft, das der Regel entspricht. Wenn ein Ereignis der Regel entspricht, wird das Ereignis an das angegebene Ziel EventBridge gesendet und die in der Regel definierte Aktion eingeleitet.

Die folgenden Tutorials zeigen, wie Sie die Ausführung einer Pipeline EventBridge mithilfe der EventBridge Konsole oder der AWS CLI planen. 

Voraussetzungen

Erstellen Sie eine EventBridge Regel mithilfe der EventBridge Konsole

Das folgende Verfahren zeigt, wie Sie eine EventBridge Regel mithilfe der EventBridge Konsole erstellen. 

Ihre Regel ist jetzt gültig und bereit, Ihre Pipeline-Ausführungen zu initiieren.

Erstellen Sie eine EventBridge Regel mit dem AWS CLI

Das folgende Verfahren zeigt, wie Sie eine EventBridge Regel mit dem erstellen AWS CLI.

Planen Sie eine Pipeline mit SageMaker Python SDK

In den folgenden Abschnitten erfahren Sie, wie Sie Berechtigungen für den Zugriff auf EventBridge Ressourcen einrichten und Ihren Pipeline-Zeitplan mithilfe von SageMaker Python erstellenSDK.

Erforderliche Berechtigungen

Sie benötigen die erforderlichen Berechtigungen, um den Pipeline-Scheduler verwenden zu können. Gehen Sie wie folgt vor, um Ihre Berechtigungen einzurichten:

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

Erstellen Sie einen Pipeline-Zeitplan

Mithilfe des PipelineSchedule Konstruktors können Sie eine Pipeline so planen, dass sie einmal oder in einem festgelegten Intervall ausgeführt wird. Ein Pipelineplan muss vom Typ atrate, oder cron sein. Dieser Satz von Planungstypen ist eine Erweiterung der EventBridge Planungsoptionen. Weitere Informationen zur Verwendung der PipelineSchedule Klasse finden Sie unter sagemaker.workflow.triggers. PipelineSchedule. Das folgende Beispiel zeigt, wie Sie jeden Planungstyp mit erstellenPipelineSchedule.

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"
)

Hängen Sie den Trigger an Ihre Pipeline an

Um Ihren an Ihre PipelineSchedule Pipeline anzuhängen, rufen Sie den put_triggers Aufruf für Ihr erstelltes Pipeline-Objekt mit einer Liste von Triggern auf. Wenn Sie eine Antwort erhaltenARN, haben Sie den Zeitplan erfolgreich in Ihrem Konto erstellt und EventBridge beginnen, die Zielpipeline zum angegebenen Zeitpunkt oder mit der angegebenen Geschwindigkeit aufzurufen. Sie müssen eine Rolle mit den richtigen Berechtigungen angeben, um Trigger an eine übergeordnete Pipeline anzuhängen. Wenn Sie keine angeben, ruft Pipelines die Standardrolle, die zum Erstellen der Pipeline verwendet wurde, aus der Konfigurationsdatei ab.

Das folgende Beispiel zeigt, wie ein Zeitplan an eine Pipeline angehängt wird.

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>)

Beschreiben Sie aktuelle Auslöser

Um Informationen über Ihre erstellten Pipeline-Trigger abzurufen, können Sie den describe_trigger() API mit dem Namen des Triggers aufrufen. Dieser Befehl gibt Details zum erstellten Zeitplanausdruck zurück, z. B. die Startzeit, den Aktivierungsstatus und andere nützliche Informationen. Das folgende Snippet zeigt einen Beispielaufruf:

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

Ressourcen für Cleanup-Trigger

Bevor Sie Ihre Pipeline löschen, sollten Sie vorhandene Auslöser bereinigen, um ein Ressourcenleck in Ihrem Konto zu vermeiden. Sie sollten die Trigger löschen, bevor Sie die übergeordnete Pipeline zerstören. Sie können Ihre Trigger löschen, indem Sie eine Liste mit Triggernamen an die übergeben delete_triggersAPI. Das folgende Snippet zeigt, wie Sie Trigger löschen.

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