Aggiornamento di applicazioni Python - Servizio gestito per Apache Flink

Amazon Managed Service for Apache Flink (Amazon MSF) era precedentemente noto come Amazon Kinesis Data Analytics for 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