Il servizio gestito da Amazon per Apache Flink era precedentemente noto come Analisi dei dati Amazon Kinesis per Apache Flink.

Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.

Utilizzo delle proprietà di runtime in Managed Service for Apache Flink

È possibile utilizzare le proprietà di runtime per configurare l'applicazione senza ricompilare il codice dell'applicazione.

Gestisci le proprietà di runtime utilizzando la console

È possibile aggiungere, aggiornare o rimuovere le proprietà di runtime dall'applicazione Managed Service for Apache Flink utilizzando. AWS Management Console

Gestite le proprietà di runtime utilizzando il CLI

Puoi aggiungere, aggiornare o rimuovere le proprietà di runtime utilizzando la AWS CLI.

Questa sezione include esempi di richieste di API azioni per la configurazione delle proprietà di runtime per un'applicazione. Per informazioni su come utilizzare un JSON file come input per un'APIazione, vedereCodice di esempio dell'API Managed Service per Apache Flink.

Aggiungi proprietà di runtime durante la creazione di un'applicazione

Il seguente esempio di richiesta per l'operazione CreateApplication aggiunge due gruppi di proprietà di runtime (ProducerConfigProperties e ConsumerConfigProperties) quando crei un'applicazione:

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

Aggiungere e aggiornare le proprietà di runtime in un'applicazione esistente

La seguente richiesta per l'operazione UpdateApplication aggiunge o aggiorna le proprietà di runtime per un'applicazione esistente:

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

Rimuovere le proprietà di runtime

La seguente richiesta per l'operazione UpdateApplication rimuove tutte le proprietà di runtime e i gruppi di proprietà da un'applicazione esistente:

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

Accedi alle proprietà di runtime in un'applicazione Managed Service for Apache Flink

È possibile recuperare le proprietà di runtime nel codice dell'applicazione Java utilizzando il metodo statico KinesisAnalyticsRuntime.getApplicationProperties(), che restituisce un oggetto Map<String, Properties>.

Il seguente esempio di codice Java recupera le proprietà di runtime per l'applicazione:

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

Recupera un gruppo di proprietà (come oggetto Java.Util.Properties) nel modo seguente:

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

In genere si configura un'origine o un sink Apache Flink passando nell'oggetto Properties senza bisogno di recuperare le singole proprietà. Il seguente esempio di codice dimostra come creare un'origine Flink passando un oggetto Properties recuperato dalle proprietà di runtime:

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;
}

Per alcuni esempi di codice, consulta Esempi di creazione e utilizzo di Managed Service per applicazioni Apache Flink.