Amazon Managed Service para Apache Flink Amazon (Amazon MSF) se denominaba anteriormente Amazon Kinesis Data Analytics para Apache Flink.

Administración de copias de seguridad de aplicaciones con instantáneas

Una instantánea es la implementación de Managed Service para Apache Flink en un punto de guardado de Apache Flink. Una instantánea es una copia de seguridad del estado de la aplicación activada, creada y gestionada por el usuario o el servicio. Para obtener información sobre los puntos de guardado de Apache Flink, consulte Savepoints en la documentación de Apache Flink. Con las instantáneas, se puede reiniciar una aplicación a partir de una instantánea concreta del estado de la aplicación.

En Managed Service para Apache Flink, las instantáneas se administran mediante las siguientes acciones de la API:

Para conocer el límite en el número de instantáneas por aplicación, consulte Cuota de cuadernos de Managed Service para Apache Flink y cuadernos de Studio. Si la aplicación alcanza el límite de instantáneas, la creación manual de una instantánea produce un error con una LimitExceededException.

Managed Service para Apache Flink nunca borra las instantáneas. Usted debe eliminar las instantáneas manualmente usando la acción DeleteApplicationSnapshot.

Para cargar una instantánea guardada del estado de la aplicación al iniciar una aplicación, utilice el parámetro ApplicationRestoreConfiguration de la acción StartApplication o UpdateApplication.

Administración de creación de instantáneas automáticas

Si SnapshotsEnabled se establece en true en ApplicationSnapshotConfiguration para la aplicación, Managed Service para Apache Flink crea y usa instantáneas automáticamente cuando la aplicación se actualiza, escala o detiene para proporcionar una semántica de procesamiento de una sola vez.

Las instantáneas creadas automáticamente tienen las siguientes cualidades:

Restauración de una instantánea que contiene datos de estado incompatibles

Como las instantáneas contienen información sobre los operadores, la restauración de los datos de estado de una instantánea para un operador que ha cambiado desde la versión anterior de la aplicación puede tener resultados inesperados. Una aplicación fallará si intenta restaurar los datos de estado de una instantánea que no corresponde al operador actual. La aplicación con errores se bloqueará en el estado STOPPING o UPDATING.

Para permitir que una aplicación se restaure a partir de una instantánea que contiene datos de estado incompatibles, establezca el parámetro AllowNonRestoredState de FlinkRunConfiguration en true mediante la acción UpdateApplication.

Verá el siguiente comportamiento cuando se restaure una aplicación a partir de una instantánea obsoleta:

Si necesita reanudar una aplicación que no es compatible con los datos de puntos de guardado existentes, se recomienda que omita la restauración a partir de la instantánea estableciendo el parámetro ApplicationRestoreType de la acción StartApplication en SKIP_RESTORE_FROM_SNAPSHOT.

Para obtener más información sobre cómo Apache Flink trata los datos de estado incompatibles, consulte State Schema Evolution en la documentación de Apache Flink.

Revisión de ejemplos de la API de instantáneas

En esta sección se incluyen solicitudes de ejemplo de acciones de API para usar instantáneas con una aplicación. Para obtener información sobre cómo utilizar un archivo JSON como entrada para una acción de API, consulte Ejemplo de código de API de Managed Service para Apache Flink.

Habilitación de las instantáneas para una aplicación

La siguiente solicitud de ejemplo de la acción UpdateApplication habilita las instantáneas para una aplicación:

{
   "ApplicationName": "MyApplication",
   "CurrentApplicationVersionId": 1,
   "ApplicationConfigurationUpdate": { 
      "ApplicationSnapshotConfigurationUpdate": { 
         "SnapshotsEnabledUpdate": "true"
       }
    }
}

Crear una instantánea

La siguiente solicitud de ejemplo de la acción CreateApplicationSnapshot crea una instantánea del estado actual de la aplicación:

{
   "ApplicationName": "MyApplication",
   "SnapshotName": "MyCustomSnapshot"
}

Lista de instantáneas de una aplicación

La siguiente solicitud de ejemplo de la acción ListApplicationSnapshots muestra las 50 primeras instantáneas del estado actual de la aplicación:

{
   "ApplicationName": "MyApplication",
   "Limit": 50
}

Lista de detalles de la instantánea de una aplicación

En la siguiente solicitud de ejemplo de la acción DescribeApplicationSnapshot se muestran los detalles de una instantánea específica de una aplicación:

{
   "ApplicationName": "MyApplication",
   "SnapshotName": "MyCustomSnapshot"
}

Eliminar una instantánea

La siguiente solicitud de ejemplo de la acción DeleteApplicationSnapshot elimina una instantánea guardada anteriormente. Se puede obtener el valor de SnapshotCreationTimestamp usando ListApplicationSnapshots o DeleteApplicationSnapshot:

{
   "ApplicationName": "MyApplication",
   "SnapshotName": "MyCustomSnapshot",
   "SnapshotCreationTimestamp": 12345678901.0,
}

Reinicio de una aplicación usando una instantánea con nombre

La siguiente solicitud de ejemplo de la acción StartApplication inicia la aplicación utilizando el estado guardado de una instantánea específica:

{
   "ApplicationName": "MyApplication",
   "RunConfiguration": { 
      "ApplicationRestoreConfiguration": { 
         "ApplicationRestoreType": "RESTORE_FROM_CUSTOM_SNAPSHOT",
         "SnapshotName": "MyCustomSnapshot"
      }
   }
}

Reinicio de una aplicación usando la instantánea más reciente

La siguiente solicitud de ejemplo de la acción StartApplication inicia la aplicación usando la instantánea más reciente:

{
   "ApplicationName": "MyApplication",
   "RunConfiguration": { 
      "ApplicationRestoreConfiguration": { 
         "ApplicationRestoreType": "RESTORE_FROM_LATEST_SNAPSHOT"
      }
   }
}

Reinicio de una aplicación sin utilizar ninguna instantánea

La siguiente solicitud de ejemplo de la acción StartApplication inicia la aplicación sin cargar el estado de la aplicación, incluso si está presente una instantánea:

{
   "ApplicationName": "MyApplication",
   "RunConfiguration": { 
      "ApplicationRestoreConfiguration": { 
         "ApplicationRestoreType": "SKIP_RESTORE_FROM_SNAPSHOT"
      }
   }
}