Creare un servizio gestito per l'applicazione Apache Flink - Servizio gestito per Apache Flink
Crea il codice dell'applicazione Managed Service for Apache FlinkCrea la tua applicazione Managed Service for Apache FlinkAvvia l'applicazione Managed Service for Apache FlinkVerifica l'applicazione Managed Service for Apache Flink

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

Creare un servizio gestito per l'applicazione Apache Flink

Questo argomento contiene informazioni sulla creazione di un servizio gestito per l'applicazione Apache Flink.

Questo argomento contiene le sezioni seguenti:

Crea il codice dell'applicazione Managed Service for Apache Flink

Questa sezione descrive i componenti utilizzati per creare il codice dell'applicazione Managed Service for Apache Flink.

Per il codice dell'applicazione, ti consigliamo di utilizzare la versione di Apache Flink supportata più recente. Per informazioni sull'aggiornamento delle applicazioni del servizio gestito per Apache Flink, consulta Usa gli aggiornamenti di versione sul posto per Apache Flink.

Il codice dell'applicazione viene creato utilizzando Apache Maven. Un progetto Apache Maven utilizza un file pom.xml per specificare le versioni dei componenti che utilizza.

Nota

Il servizio gestito per Apache Flink supporta JAR file di dimensioni fino a 512 MB. Se si utilizza un JAR file di dimensioni superiori a questo, l'applicazione non verrà avviata.

Le applicazioni possono ora utilizzare Java API da qualsiasi versione di Scala. È necessario includere la libreria standard Scala di propria scelta nelle applicazioni Scala.

Per informazioni sulla creazione di un'applicazione del servizio gestito per Apache Flink che utilizza Apache Beam, consulta Usa Apache Beam con Managed Service per le applicazioni Apache Flink.

Quando utilizzi il servizio gestito per il runtime di Apache Flink versione 1.1.0, devi specificare la versione di Apache Flink che l'applicazione utilizza durante la compilazione. Fornisci la versione di Apache Flink con il parametro. -Dflink.version Ad esempio, se utilizzi Apache Flink 1.19.1, fornisci quanto segue:

mvn package -Dflink.version=1.19.1

Per creare applicazioni con versioni precedenti di Apache Flink, vedi. Versioni precedenti

Crea la tua applicazione Managed Service for Apache Flink

Dopo aver creato il codice dell'applicazione, procedi come segue per creare l'applicazione Managed Service for Apache Flink:

  • Carica il codice dell'applicazione: carica il codice dell'applicazione in un bucket Amazon S3. Quando crei l'applicazione, specifica il nome del bucket S3 e il nome oggetto del codice dell'applicazione. Per un tutorial che mostra come caricare il codice dell'applicazione, consulta il Tutorial: inizia a usare Managed Service for Apache Flink DataStream API tutorial.

  • Creazione dell'applicazione del servizio gestito per Apache Flink: utilizza uno dei seguenti metodi per creare l'applicazione del servizio gestito per Apache Flink:

    • Crea la tua applicazione Managed Service for Apache Flink utilizzando la AWS console: puoi creare e configurare la tua applicazione utilizzando la AWS console.

      Quando crei l'applicazione utilizzando la console, le risorse dipendenti dall'applicazione (come CloudWatch i flussi di log, i IAM ruoli e IAM le politiche) vengono create automaticamente.

      Quando crei l'applicazione utilizzando la console, devi specificare la versione di Apache Flink utilizzata dall'applicazione selezionandola dal menu a discesa nella pagina Servizio gestito per Apache Flink: crea applicazione.

      Per un tutorial su come utilizzare la console per creare un'applicazione, consulta il Tutorial: inizia a usare Managed Service for Apache Flink DataStream API tutorial.

    • Crea il tuo servizio gestito per l'applicazione Apache Flink utilizzando AWS CLI: Puoi creare e configurare la tua applicazione utilizzando. AWS CLI

      Quando create l'applicazione utilizzando ilCLI, dovete anche creare manualmente le risorse dipendenti dall'applicazione (come flussi di CloudWatch log, IAM ruoli e IAM politiche).

      Quando create l'applicazione utilizzandoCLI, specificate la versione di Apache Flink utilizzata dall'applicazione utilizzando il RuntimeEnvironment parametro dell'azione. CreateApplication

    Nota

    È possibile modificare il nome RuntimeEnvironment di un'applicazione esistente. Per scoprire come, consulta Usa gli aggiornamenti di versione sul posto per Apache Flink.

Avvia l'applicazione Managed Service for Apache Flink

Dopo aver creato il codice dell'applicazione, averlo caricato su S3 e aver creato l'applicazione del servizio gestito per Apache Flink, è il momento di avviare l'applicazione. L'avvio di un'applicazione del servizio gestito per Apache Flink richiede in genere alcuni minuti.

Per avviare l'applicazione, utilizza uno dei seguenti metodi:

  • Avvia l'applicazione Managed Service for Apache Flink utilizzando la AWS console: puoi eseguire l'applicazione scegliendo Esegui nella pagina dell'applicazione nella console. AWS

  • Avvia l'applicazione Managed Service for Apache Flink utilizzando AWS API: Puoi eseguire l'applicazione utilizzando l'azione. StartApplication

Verifica l'applicazione Managed Service for Apache Flink

È possibile verificare il funzionamento dell'applicazione nei seguenti modi:

  • Utilizzo CloudWatch dei registri: è possibile utilizzare CloudWatch Logs and CloudWatch Logs Insights per verificare che l'applicazione funzioni correttamente. Per informazioni sull'utilizzo di CloudWatch Logs con l'applicazione Managed Service for Apache Flink, consulta. Registrazione e monitoraggio in Amazon Managed Service per Apache Flink

  • Utilizzo CloudWatch delle metriche: puoi utilizzare CloudWatch Metrics per monitorare l'attività dell'applicazione o l'attività delle risorse utilizzate dall'applicazione per l'input o l'output (come i flussi Kinesis, i flussi Firehose o i bucket Amazon S3). Per ulteriori informazioni sui CloudWatch parametri, consulta Working with Metrics nella Amazon CloudWatch User Guide.

  • Monitoraggio delle posizioni di output: se l'applicazione scrive l'output in una posizione (come un bucket o un database Amazon S3), è possibile monitorare quella posizione per i dati scritti.