View a markdown version of this page

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

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 file Java JAR 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"
          }
        },