Las traducciones son generadas a través de traducción automática. En caso de conflicto entre la traducción y la version original de inglés, prevalecerá la version en inglés.

Programe los recorridos de las tuberías

Puedes programar tus ejecuciones de Amazon SageMaker Pipelines con Amazon EventBridge. Amazon admite Amazon SageMaker Pipelines como destino. EventBridge Esto le permite iniciar la ejecución de su canalización de creación de modelos en función de cualquier evento del bus de eventos. Con él EventBridge, puede automatizar las ejecuciones de sus canalizaciones y responder automáticamente a eventos como los cambios en el estado de los puntos finales, tareas o tareas de formación. Los eventos incluyen la carga de un nuevo archivo en tu bucket de Amazon S3, un cambio en el estado de tu SageMaker punto de conexión de Amazon debido a una desviación y temas relacionados con Amazon Simple Notification Service (SNS).

Las siguientes acciones de Pipelines se pueden iniciar automáticamente: 

Para obtener más información sobre la programación de SageMaker trabajos, consulta Automatizar SageMaker con Amazon EventBridge.

Programa una canalización con Amazon EventBridge

Para iniciar la ejecución de una canalización con Amazon CloudWatch Events, debe crear una EventBridge regla. Al crear una regla para los eventos, se especifica la acción objetivo que se debe realizar cuando se EventBridge recibe un evento que coincide con la regla. Cuando un evento coincide con la regla, EventBridge envía el evento al destino especificado e inicia la acción definida en la regla.

Los siguientes tutoriales muestran cómo programar la ejecución de una canalización EventBridge mediante la EventBridge consola o el AWS CLI. 

Requisitos previos

Cree una EventBridge regla mediante la EventBridge consola

El siguiente procedimiento muestra cómo crear una EventBridge regla mediante la EventBridge consola. 

La regla ya está en vigor y lista para iniciar las ejecuciones de la canalización.

Cree una EventBridge regla mediante el AWS CLI

En el siguiente procedimiento se muestra cómo crear una EventBridge regla mediante AWS CLI.

Programa una canalización con SageMaker Python SDK

En las siguientes secciones, se muestra cómo configurar los permisos para acceder a EventBridge los recursos y crear el cronograma de canalización mediante SageMaker PythonSDK.

Permisos necesarios

Debes tener los permisos necesarios para usar el programador de canalizaciones. Complete los siguientes pasos para configurar sus permisos:

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

Cree un cronograma de canalización

Con el PipelineSchedule constructor, puedes programar una canalización para que se ejecute una vez o en un intervalo predeterminado. El cronograma de una canalización debe ser del tipo atrate, ocron. Este conjunto de tipos de programación es una extensión de las opciones de EventBridge programación. Para obtener más información sobre cómo usar la PipelineSchedule clase, consulte sagemaker.workflow.triggers. PipelineSchedule. El siguiente ejemplo muestra cómo crear cada tipo de programación conPipelineSchedule.

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

Conecta el disparador a tu canalización

Para adjuntarlo PipelineSchedule a tu canalización, invoca la put_triggers llamada en el objeto de canalización que hayas creado con una lista de factores desencadenantes. Si recibes una respuestaARN, habrás creado correctamente la programación en tu cuenta y EventBridge empezarás a invocar la canalización de destino a la hora o al ritmo especificados. Debes especificar un rol con los permisos correctos para adjuntar los activadores a una canalización principal. Si no lo proporcionas, Pipelines busca el rol predeterminado que se usa para crear la canalización desde el archivo de configuración.

En el siguiente ejemplo, se muestra cómo adjuntar un cronograma a una canalización.

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

Describa los desencadenantes actuales

Para obtener información sobre los activadores de canalización que has creado, puedes invocarlos describe_trigger() API con el nombre del activador. Este comando devuelve detalles sobre la expresión de programación creada, como la hora de inicio, el estado de activación y otra información útil. En el siguiente fragmento se muestra un ejemplo de invocación:

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

Recursos desencadenantes de limpieza

Antes de eliminar tu canalización, limpia los activadores existentes para evitar una pérdida de recursos en tu cuenta. Debes eliminar los activadores antes de destruir la canalización principal. Para eliminar los activadores, pase una lista de los nombres de los activadores al delete_triggersAPI. En el siguiente fragmento se muestra cómo eliminar los desencadenadores.

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