Verwenden Sie Laufzeiteigenschaften in Managed Service für Apache Flink

Sie können Laufzeiteigenschaften verwenden, um Ihre Anwendung zu konfigurieren, ohne Ihren Anwendungscode neu zu kompilieren.

Verwalten Sie Runtime-Eigenschaften mithilfe der Konsole

Sie können Runtime-Eigenschaften zu Ihrer Managed Service for Apache Flink-Anwendung hinzufügen, aktualisieren oder entfernen, indem Sie die AWS Management Console.

Anmerkung

Wenn Sie eine frühere unterstützte Version von Apache Flink verwenden und Ihre vorhandenen Anwendungen auf Apache Flink 1.19.1 aktualisieren möchten, können Sie dazu direkte Apache Flink-Versionsupgrades verwenden. Mit direkten Versionsupgrades behalten Sie die Rückverfolgbarkeit der Anwendung anhand einer einzelnen ARN Apache Flink-Version, einschließlich Snapshots, Protokollen, Metriken, Tags, Flink-Konfigurationen und mehr. Sie können diese Funktion in jedem beliebigen Bundesstaat verwenden. RUNNING READY Weitere Informationen finden Sie unter Verwenden Sie direkte Versionsupgrades für Apache Flink.

Aktualisieren von Laufzeiteigenschaften für eine Anwendung, die Managed Service für Apache Flink nutzt

1. Öffnen Sie die Managed Service for Apache Flink-Konsole unter https://console.aws.amazon.com /flink

2. Wählen Sie Ihre Anwendung, die Managed Service für Apache Flink nutzt. Wählen Sie Anwendungsdetails aus.

3. Wählen Sie auf der Seite für Ihre Anwendung Konfigurieren aus.

4. Erweitern Sie den Bereich Eigenschaften.

5. Verwenden Sie die Steuerelemente im Abschnitt Eigenschaften, um eine Eigenschaftsgruppe mit Schlüssel-Wert-Paaren zu definieren. Verwenden Sie diese Steuerelemente, um Eigenschaftsgruppen und Laufzeiteigenschaften hinzuzufügen, zu aktualisieren oder zu entfernen.

6. Wählen Sie Aktualisieren.

Verwalten Sie Laufzeiteigenschaften mit dem CLI

Sie können Laufzeiteigenschaften mit der AWS CLI hinzufügen, aktualisieren oder entfernen.

Dieser Abschnitt enthält Beispielanfragen für API Aktionen zur Konfiguration von Laufzeiteigenschaften für eine Anwendung. Hinweise zur Verwendung einer JSON Datei als Eingabe für eine API Aktion finden Sie unterAPIBeispielcode für Managed Service für Apache Flink.

Anmerkung

Ersetzen Sie die Beispielkonto-ID (012345678901) in den folgenden Beispielen mit Ihrer Konto-ID.

Fügen Sie Runtime-Eigenschaften hinzu, wenn Sie eine Anwendung erstellen

Die folgende Beispielanfrage für die CreateApplication-Aktion fügt zwei Laufzeiteigenschaftsgruppen (ProducerConfigProperties und ConsumerConfigProperties) hinzu, wenn Sie eine Anwendung erstellen:

{
    "ApplicationName": "MyApplication",
    "ApplicationDescription": "my java test app",
    "RuntimeEnvironment": "FLINK-1_19",
    "ServiceExecutionRole": "arn:aws:iam::012345678901:role/MF-stream-rw-role",
    "ApplicationConfiguration": {
        "ApplicationCodeConfiguration": {
            "CodeContent": {
                "S3ContentLocation": {
                    "BucketARN": "arn:aws:s3:::ka-app-code-username",
                    "FileKey": "java-getting-started-1.0.jar"
                }
            },
            "CodeContentType": "ZIPFILE"
        },
        "EnvironmentProperties":  { 
         "PropertyGroups": [ 
            { 
               "PropertyGroupId": "ProducerConfigProperties",
               "PropertyMap" : {
                    "flink.stream.initpos" : "LATEST",
                    "aws.region" : "us-west-2",
                    "AggregationEnabled" : "false"
               }
            },
            { 
               "PropertyGroupId": "ConsumerConfigProperties",
               "PropertyMap" : {
                    "aws.region" : "us-west-2"
               }
            }
         ]
      }
    }
}

Fügen Sie Runtime-Eigenschaften in einer vorhandenen Anwendung hinzu und aktualisieren Sie sie

Mit der folgenden Beispielanfrage für die UpdateApplication-Aktion werden Laufzeiteigenschaften für eine bestehende Anwendung hinzugefügt oder aktualisiert:

{
  "ApplicationName": "MyApplication",
  "CurrentApplicationVersionId": 2,
  "ApplicationConfigurationUpdate": {
    "EnvironmentPropertyUpdates": {
      "PropertyGroups": [ 
        { 
          "PropertyGroupId": "ProducerConfigProperties",
          "PropertyMap" : {
            "flink.stream.initpos" : "LATEST",
            "aws.region" : "us-west-2",
            "AggregationEnabled" : "false"
          }
        },
        { 
          "PropertyGroupId": "ConsumerConfigProperties",
          "PropertyMap" : {
            "aws.region" : "us-west-2"
          }
        }
      ]
    }
  }
}

Anmerkung

Wenn Sie in einer Eigenschaftsgruppe einen Schlüssel verwenden, für den keine entsprechende Laufzeiteigenschaft vorhanden ist, fügt Managed Service für Apache Flink das Schlüssel-Wert-Paar als neue Eigenschaft hinzu. Wenn Sie einen Schlüssel für eine vorhandene Laufzeiteigenschaft in einer Eigenschaftsgruppe verwenden, aktualisiert Managed Service für Apache Flink den Eigenschaftswert.

Laufzeiteigenschaften entfernen

Mit der folgenden Beispielanfrage für die UpdateApplication-Aktion werden alle Laufzeiteigenschaften und Eigenschaftsgruppen aus einer bestehenden Anwendung entfernt:

{
  "ApplicationName": "MyApplication",
  "CurrentApplicationVersionId": 3,
  "ApplicationConfigurationUpdate": {
    "EnvironmentPropertyUpdates": {
      "PropertyGroups": []
    }
  }
}

Wichtig

Wenn Sie eine vorhandene Eigenschaftsgruppe oder einen vorhandenen Eigenschaftsschlüssel in einer Eigenschaftsgruppe weglassen, wird diese Eigenschaftsgruppe oder Eigenschaft entfernt.

Greifen Sie auf Laufzeiteigenschaften in einer Managed Service for Apache Flink-Anwendung zu

Sie rufen Laufzeiteigenschaften in Ihrem Java-Anwendungscode mithilfe der statischen KinesisAnalyticsRuntime.getApplicationProperties()-Methode ab, die ein Map<String, Properties>-Objekt zurückgibt.

Im folgenden Java-Codebeispiel werden Laufzeiteigenschaften für Ihre Anwendung abgerufen:

 Map<String, Properties> applicationProperties = KinesisAnalyticsRuntime.getApplicationProperties();

Sie rufen eine Eigenschaftsgruppe (als Java.Util.Properties-Objekt) wie folgt ab:

Properties consumerProperties = applicationProperties.get("ConsumerConfigProperties");

Normalerweise konfigurieren Sie eine Apache-Flink-Quelle oder -Senke, indem Sie das Properties-Objekt übergeben, ohne die einzelnen Eigenschaften abrufen zu müssen. Das folgende Codebeispiel zeigt, wie Sie eine Flink-Quelle erstellen, indem Sie ein Properties-Objekt übergeben, das aus Laufzeiteigenschaften abgerufen wurde:

private static FlinkKinesisProducer<String> createSinkFromApplicationProperties() throws IOException {
  Map<String, Properties> applicationProperties = KinesisAnalyticsRuntime.getApplicationProperties();
  FlinkKinesisProducer<String> sink = new FlinkKinesisProducer<String>(new SimpleStringSchema(),
    applicationProperties.get("ProducerConfigProperties"));

  sink.setDefaultStream(outputStreamName);
  sink.setDefaultPartition("0");
  return sink;
}

Codebeispiele finden Sie unter Beispiele für die Erstellung und Arbeit mit Managed Service für Apache Flink-Anwendungen.