View a markdown version of this page

Aggiornamento di applicazioni Python - Servizio gestito 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à.

Aggiornamento di applicazioni Python

Le applicazioni Python possono utilizzare i connettori in due maniere diverse: per impacchettare connettori e altre dipendenze Java come parte di un singolo uber jar o utilizzare direttamente il connettore jar. Per correggere le applicazioni interessate dal blocco di Async sink:

Creazione di connettori dalla fonte:

Prerequisiti, simili ai requisiti per la costruzione di Flink:

  • Java 11

  • Maven 3.2.5

  1. Scarica il codice sorgente per Flink 1.15.4:

    wget https://archive.apache.org/dist/flink/flink-1.15.4/flink-1.15.4-src.tgz

  2. Decomprimi il codice sorgente:

    tar -xvf flink-1.15.4-src.tgz

  3. Vai alla directory del connettore Kinesis

    cd flink-1.15.4/flink-connectors/flink-connector-kinesis/

  4. Compila e installa il connettore jar, specificando la versione SDK richiesta. AWS Per velocizzare la compilazione, usa -DskipTests per saltare l'esecuzione dei test e -Dfast per saltare i controlli aggiuntivi del codice sorgente:

    mvn clean install -DskipTests -Dfast -Daws.sdkv2.version=2.20.144

  5. Vai alla directory del connettore Kinesis

    cd ../flink-sql-connector-kinesis

  6. Compilare e installare il connettore jar sql:

    mvn clean install -DskipTests -Dfast

  7. Il jar risultante sarà disponibile all'indirizzo:

    target/flink-sql-connector-kinesis-1.15.4.jar

  1. Scarica il codice sorgente per Flink 1.15.4:

    wget https://archive.apache.org/dist/flink/flink-1.15.4/flink-1.15.4-src.tgz

  2. Decomprimi il codice sorgente:

    tar -xvf flink-1.15.4-src.tgz

  3. Vai alla directory del connettore Kinesis

    cd flink-1.15.4/flink-connectors/flink-connector-aws-kinesis-streams/

  4. Compila e installa il connector jar, specificando la versione SDK richiesta. AWS Per velocizzare la compilazione, usa -DskipTests per saltare l'esecuzione dei test e -Dfast per saltare i controlli aggiuntivi del codice sorgente:

    mvn clean install -DskipTests -Dfast -Daws.sdk.version=2.20.144

  5. Vai alla directory del connettore Kinesis

    cd ../flink-sql-connector-aws-kinesis-streams

  6. Compilare e installare il connettore jar sql:

    mvn clean install -DskipTests -Dfast

  7. Il jar risultante sarà disponibile all'indirizzo:

    target/flink-sql-connector-aws-kinesis-streams-1.15.4.jar

  1. Scarica il codice sorgente per Flink 1.15.4:

    wget https://archive.apache.org/dist/flink/flink-1.15.4/flink-1.15.4-src.tgz

  2. Decomprimi il codice sorgente:

    tar -xvf flink-1.15.4-src.tgz

  3. Accedi alla directory del connettore

    cd flink-1.15.4/flink-connectors/flink-connector-aws-kinesis-firehose/

  4. Compila e installa il connettore jar, specificando la versione SDK richiesta. AWS Per velocizzare la compilazione, usa -DskipTests per saltare l'esecuzione dei test e -Dfast per saltare i controlli aggiuntivi del codice sorgente:

    mvn clean install -DskipTests -Dfast -Daws.sdk.version=2.20.144

  5. Accedi alla directory del connettore sql

    cd ../flink-sql-connector-aws-kinesis-firehose

  6. Compilare e installare il connettore jar sql:

    mvn clean install -DskipTests -Dfast

  7. Il jar risultante sarà disponibile all'indirizzo:

    target/flink-sql-connector-aws-kinesis-firehose-1.15.4.jar

  1. Scarica il codice sorgente per Flink 1.15.4:

    wget https://archive.apache.org/dist/flink/flink-connector-aws-3.0.0/flink-connector-aws-3.0.0-src.tgz

  2. Decomprimi il codice sorgente:

    tar -xvf flink-connector-aws-3.0.0-src.tgz

  3. Accedi alla directory del connettore

    cd flink-connector-aws-3.0.0

  4. Compila e installa il connettore jar, specificando la versione SDK richiesta. AWS Per velocizzare la compilazione, usa -DskipTests per saltare l'esecuzione dei test e -Dfast per saltare i controlli aggiuntivi del codice sorgente:

    mvn clean install -DskipTests -Dfast -Dflink.version=1.15.4 -Daws.sdk.version=2.20.144

  5. Il jar risultante sarà disponibile all'indirizzo:

    flink-sql-connector-dynamodb/target/flink-sql-connector-dynamodb-3.0.0.jar