Amazon Managed Service für Apache Flink war zuvor als Amazon Kinesis Data Analytics für Apache Flink bekannt.

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 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.

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 unterBeispielcode für Managed Service für Apache Flink API.

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

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": []
    }
  }
}

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.