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

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.

Gestione las copias de seguridad de las aplicaciones mediante 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 almacenamiento de Apache Flink, consulte los puntos de almacenamiento en la documentación de Apache Flink. Con las instantáneas, puede reiniciar una aplicación a partir de una instantánea concreta del estado de la aplicación.

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

Para conocer el límite en el número de instantáneas por aplicación, consulte Servicio gestionado para la cuota de portátiles Apache Flink y 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.

Administre la creación automática de instantáneas

Si SnapshotsEnabled está configurado como ApplicationSnapshotConfigurationpara la aplicación, Managed Service for Apache Flink crea y utiliza automáticamente las instantáneas cuando la aplicación se actualiza, se escala o se detiene para proporcionar una semántica de procesamiento de una sola vez. true

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

Restaure a partir de una instantánea que contenga 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, FlinkRunConfigurationdefina el AllowNonRestoredState parámetro para true utilizar la UpdateApplicationacción.

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 almacenamiento existentes, le recomendamos que omita la restauración desde la instantánea configurando el ApplicationRestoreType parámetro de la acción en. StartApplicationSKIP_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.

Revise los ejemplos de instantáneas API

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

Habilitar 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"
}

Enumere las 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
}

Enumere los detalles de una instantánea de la 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. Puede obtener el valor de SnapshotCreationTimestamp usando ListApplicationSnapshots o DeleteApplicationSnapshot:

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

Reinicie una aplicación mediante 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"
      }
   }
}

Reinicie una aplicación con 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"
      }
   }
}

Reinicie 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"
      }
   }
}