Crea il tuo servizio gestito per l'applicazione Apache Flink Python - Servizio gestito per Apache Flink
Specificate i vostri file di codice

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

Crea il tuo servizio gestito per l'applicazione Apache Flink Python

Specificate i vostri file di codice

Dopo che è stato creato, il pacchetto di codice dell'applicazione deve essere caricato in un bucket Amazon S3. Quindi crei l'applicazione utilizzando la console o l'CreateApplicationazione.

Quando create l'applicazione utilizzando l'CreateApplicationazione, specificate i file di codice e gli archivi nel file zip utilizzando uno speciale gruppo di proprietà dell'applicazione denominatokinesis.analytics.flink.run.options. Puoi definire i seguenti tipi di file:

  • python: un file di testo contenente un metodo principale Python.

  • jarfile: un JAR file Java contenente funzioni Java definite dall'utente.

  • pyFiles: un file di risorse Python contenente risorse che devono essere utilizzate dall'applicazione.

  • pyArchives: un file zip contenente i file di risorse per l'applicazione.

Per ulteriori informazioni sui tipi di file di codice Python di Apache Flink, consulta Command-Line Interface nella documentazione di Apache Flink.

Nota

Il servizio gestito per Apache Flink non supporta i tipi di file pyModule, pyExecutable o pyRequirements. Tutto il codice, tutti i requisiti e tutte le dipendenze devono essere contenuti nel file zip. Non è possibile specificare le dipendenze da installare utilizzando pip.

Il seguente esempio di frammento json mostra come specificare le posizioni dei file all'interno del file zip dell'applicazione:

"ApplicationConfiguration": {
    "EnvironmentProperties": {
      "PropertyGroups": [
        {
          "PropertyGroupId": "kinesis.analytics.flink.run.options",
          "PropertyMap": {
            "python": "MyApplication/main.py",
            "jarfile": "MyApplication/lib/myJarFile.jar",
            "pyFiles": "MyApplication/lib/myDependentFile.py",
            "pyArchives": "MyApplication/lib/myArchive.zip"
          }
        },