Les traductions sont fournies par des outils de traduction automatique. En cas de conflit entre le contenu d'une traduction et celui de la version originale en anglais, la version anglaise prévaudra.
Utiliser la mise à l'échelle automatique dans Managed Service for Apache Flink
Le service géré pour Apache Flink adapte de manière élastique le parallélisme de votre application pour s’adapter au débit de données de votre source et à la complexité de votre opérateur dans la plupart des scénarios. La mise à l’échelle automatique est activée par défaut. Le service géré pour Apache Flink surveille l’utilisation des ressources (processeur) de votre application et adapte de manière élastique le parallélisme de votre application à la hausse ou à la baisse en conséquence :
Votre application augmente (augmente le parallélisme) si le maximum de la CloudWatch métrique
containerCPUUtilizationest supérieur ou supérieur à 75 % pendant 15 minutes. Cela signifie que l'ScaleUpaction est lancée lorsqu'il y a 15 points de données consécutifs avec une période d'une minute égale ou supérieure à 75 %. UneScaleUpaction double le montantCurrentParallelismde votre candidature.ParallelismPerKPUn'est pas modifié. En conséquence, le nombre de KPU alloués double également.Votre application réduit (diminue le parallélisme) lorsque l’utilisation de votre processeur reste inférieure à 10 % pendant six heures. Cela signifie que l'
ScaleDownaction est lancée lorsqu'il existe 360 points de données consécutifs avec une période d'une minute inférieure à 10 %. UneScaleDownaction divise par deux (arrondi) le parallélisme de l'application.ParallelismPerKPUn'est pas modifié et le nombre de KPU alloués est également divisé par deux (arrondi au chiffre supérieur).
Note
Une période maximale de containerCPUUtilization plus d'une minute peut être référencée pour trouver la corrélation avec un point de données utilisé pour l'action Scaling, mais il n'est pas nécessaire de refléter le moment exact où l'action est initialisée.
Le service géré pour Apache Flink ne réduira pas la valeur CurrentParallelism de votre application à un niveau inférieur au paramètre Parallelism de votre application.
Lorsque le service géré pour Apache Flink met à l’échelle votre application, elle passe à l’état AUTOSCALING. Vous pouvez vérifier l'état actuel de votre demande à l'aide ListApplications des actions DescribeApplication ou. Pendant que le service fait évoluer votre application, la seule action d'API valide que vous pouvez utiliser est StopApplication de définir le Force paramètre surtrue.
Vous pouvez utiliser la propriété AutoScalingEnabled (partie de FlinkApplicationConfiguration) pour activer ou désactiver le comportement de l’autoscaling. Votre AWS compte est facturé pour les KPU fournis par Managed Service for Apache Flink, en fonction de votre application parallelism et parallelismPerKPU de ses paramètres. Un pic d’activité augmente les coûts de votre service géré pour Apache Flink.
Pour obtenir des informations sur la tarification, consultez Tarification du service géré pour Apache Flink
Notez les informations suivantes à propos de la mise à l’échelle de l’application :
La mise à l’échelle automatique est activée par défaut.
La mise à l’échelle ne s’applique pas aux blocs-notes Studio. Toutefois, si vous déployez un bloc-notes Studio en tant qu’application à état durable, la mise à l’échelle s’appliquera à l’application déployée.
La limite par défaut de votre application est de 64 KPU. Pour de plus amples informations, veuillez consulter Service géré pour Apache Flink et quota de blocs-notes Studio.
Lorsque la mise à l’échelle automatique met à jour le parallélisme des applications, celles-ci subissent des interruptions. Pour éviter ces interruptions, procédez comme suit :
Désactiver la mise à l’échelle automatique
Configurez le
parallelismet l'UpdateApplicationactionparallelismPerKPUde votre application. Pour plus d'informations sur la définition des paramètres de parallélisme de votre application, consultez. Mettez à jour le parallélisme de votre applicationSurveillez régulièrement l’utilisation des ressources de votre application pour vérifier qu’elle dispose des paramètres de parallélisme adaptés à sa charge de travail. Pour obtenir des informations sur la surveillance de l’allocation des ressources, consultez Métriques et dimensions dans le service géré pour Apache Flink.
Implémenter un dimensionnement automatique personnalisé
Si vous souhaitez un contrôle plus précis de la mise à l'échelle automatique ou si vous souhaitez utiliser d'autres métriques de déclenchementcontainerCPUUtilization, vous pouvez utiliser cet exemple :
-
Cet exemple montre comment dimensionner votre application Managed Service for Apache Flink à l'aide d'une CloudWatch métrique différente de celle de l'application Apache Flink, y compris des métriques provenant d'Amazon MSK et d'Amazon Kinesis Data Streams, utilisées comme sources ou récepteurs.
Pour plus d'informations, consultez la section Surveillance améliorée et dimensionnement automatique pour Apache Flink
Mettre en œuvre un dimensionnement automatique programmé
Si votre charge de travail suit un profil prévisible au fil du temps, vous préférerez peut-être faire évoluer votre application Apache Flink de manière préventive. Cela permet de dimensionner votre application à une heure planifiée, par opposition à une mise à l'échelle réactive en fonction d'une métrique. Pour configurer la mise à l'échelle vers le haut et vers le bas à des heures fixes de la journée, vous pouvez utiliser cet exemple :
