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.
Verwenden Sie die automatische Skalierung in Managed Service für Apache Flink
Managed Service für Apache Flink skaliert die Parallelität Ihrer Anwendung elastisch, um dem Datendurchsatz Ihrer Quelle und der Komplexität Ihres Operators in den meisten Szenarien Rechnung zu tragen. Die automatische Skalierung ist standardmäßig aktiviert. Managed Service für Apache Flink überwacht die Ressourcenauslastung (CPU-Auslastung) Ihrer Anwendung und skaliert die Parallelität Ihrer Anwendung entsprechend elastisch nach oben oder unten:
Ihre Anwendung skaliert (erhöht die Parallelität), wenn das CloudWatch metrische Maximum 15 Minuten lang über 75 Prozent oder mehr
containerCPUUtilizationliegt. Das bedeutet, dass dieScaleUpAktion initiiert wird, wenn 15 aufeinanderfolgende Datenpunkte mit einem Zeitraum von 1 Minute 75 Prozent oder mehr vorhanden sind. EineScaleUpAktion verdoppelt den Wert Ihrer AnwendungCurrentParallelism.ParallelismPerKPUwird nicht geändert. Infolgedessen verdoppelt sich auch die Anzahl der zugewiesenen KPUs.Ihre Anwendung wird herunterskaliert (Parallelität wird verringert), wenn die CPU-Auslastung sechs Stunden lang unter 10 Prozent bleibt. Das bedeutet, dass die
ScaleDownAktion initiiert wird, wenn 360 aufeinanderfolgende Datenpunkte mit einem Zeitraum von 1 Minute weniger als 10 Prozent vorhanden sind. EineScaleDownAktion halbiert (aufgerundet) die Parallelität der Anwendung.ParallelismPerKPUwird nicht geändert, und die Anzahl der zugewiesenen KPUs halbiert sich ebenfalls (aufgerundet).
Anmerkung
Es kann auf einen Zeitraum von maximal containerCPUUtilization über einer Minute Bezug genommen werden, um die Korrelation mit einem Datenpunkt zu ermitteln, der für die Skalierungsaktion verwendet wird. Es ist jedoch nicht erforderlich, den genauen Zeitpunkt der Initialisierung der Aktion anzugeben.
Managed Service für Apache Flink reduziert den CurrentParallelism-Wert Ihrer Anwendung nicht auf weniger als die Parallelism-Einstellung Ihrer Anwendung.
Wenn der Service von Managed Service für Apache Flink Ihre Anwendung skaliert, befindet er sich im Status AUTOSCALING. Sie können Ihren aktuellen Anwendungsstatus mithilfe der DescribeApplication Aktionen oder überprüfen. ListApplications Während der Service Ihre Anwendung skaliert, können Sie nur eine gültige API-Aktion verwenden, wenn der Force Parameter auf gesetzt ist StopApplication true.
Sie können die Eigenschaft AutoScalingEnabled (Teil von FlinkApplicationConfiguration ) verwenden, um das Auto-Scaling-Verhalten zu aktivieren oder zu deaktivieren. Ihr AWS Konto wird für KPUs belastet, die Managed Service for Apache Flink bereitstellt. Dies hängt von Ihren Anwendungen parallelism und parallelismPerKPU Einstellungen ab. Eine Aktivitätsspitze erhöht Ihre Kosten für Managed Service für Apache Flink.
Weitere Informationen finden Sie unter Amazon Managed Service für Apache Flink – Preise
Beachten Sie Folgendes im Zusammenhang mit der Anwendungsskalierung:
Die automatische Skalierung ist standardmäßig aktiviert.
Skalierung gilt nicht für Studio-Notebooks. Wenn Sie ein Studio-Notebook jedoch als Anwendung mit dauerhaftem Zustand bereitstellen, gilt die Skalierung für die bereitgestellte Anwendung.
Ihre Anwendung hat einen Standardgrenzwert von 64 KPUs. Weitere Informationen finden Sie unter Managed Service für Apache Flink und Studio Notebook-Kontingent.
Wenn Auto Scaling die Anwendungsparallelität aktualisiert, kommt es bei der Anwendung zu Ausfallzeiten. Gehen Sie wie folgt vor, um diese Ausfallzeit zu vermeiden:
Deaktivieren der automatischen Skalierung
Konfigurieren Sie das
parallelismundparallelismPerKPUmit der Aktion Ihrer Anwendung. UpdateApplication Weitere Informationen zum Festlegen der Parallelitätseinstellungen Ihrer Anwendung finden Sie unter. Aktualisieren Sie die Parallelität Ihrer AnwendungÜberwachen Sie regelmäßig den Ressourcenverbrauch Ihrer Anwendung, um sicherzustellen, dass Ihre Anwendung über die richtigen Parallelitätseinstellungen für ihren Workload verfügt. Weitere Informationen über die Überwachung des Ressourcenverbrauchs finden Sie unter Metriken und Dimensionen in Managed Service für Apache Flink.
Implementieren Sie benutzerdefiniertes Autoscaling
Wenn Sie eine feinere Steuerung der Autoskalierung wünschen oder andere Trigger-Metriken verwenden möchtencontainerCPUUtilization, können Sie dieses Beispiel verwenden:
-
Dieses Beispiel veranschaulicht, wie Sie Ihre Managed Service for Apache Flink-Anwendung mithilfe einer anderen CloudWatch Metrik als der Apache Flink-Anwendung skalieren, einschließlich Metriken aus Amazon MSK und Amazon Kinesis Data Streams, die als Quellen oder Senken verwendet werden.
Weitere Informationen finden Sie unter Verbesserte Überwachung und automatische Skalierung für Apache Flink.
Implementieren Sie geplantes Autoscaling
Wenn Ihre Arbeitslast im Laufe der Zeit einem vorhersehbaren Profil folgt, ziehen Sie es möglicherweise vor, Ihre Apache Flink-Anwendung präventiv zu skalieren. Dadurch wird Ihre Anwendung zu einem geplanten Zeitpunkt skaliert, im Gegensatz zu einer reaktiven Skalierung auf der Grundlage einer Metrik. Um das Hoch- und Herunterskalieren zu festen Tageszeiten einzurichten, können Sie dieses Beispiel verwenden:
