Usa connettori e dipendenze - Servizio gestito per Apache Flink
Connettori predefinitiAggiungi dipendenze e connettori personalizzati

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

Usa connettori e dipendenze

I connettori consentono di leggere e scrivere dati utilizzando tecnologie diverse. Il servizio gestito per Apache Flink include tre connettori predefiniti nel notebook Studio. Puoi inoltre utilizzare connettori personalizzati. Per ulteriori informazioni sui connettori, consulta Table & SQL Connectors nella documentazione di Apache Flink.

Connettori predefiniti

Se utilizzi il AWS Management Console per creare il tuo notebook Studio, Managed Service for Apache Flink include i seguenti connettori personalizzati per impostazione predefinita:, e. flink-sql-connector-kinesis flink-connector-kafka_2.12 aws-msk-iam-auth Per creare un notebook Studio tramite la console senza questi connettori personalizzati, scegli l'opzione Crea con impostazioni personalizzate. Quindi, quando arrivi alla pagina Configurazioni, deseleziona le caselle di controllo accanto ai due connettori.

Se utilizzi il CreateApplicationAPIper creare il tuo notebook Studio, i flink-connector-kafka connettori flink-sql-connector-flink e non sono inclusi per impostazione predefinita. Per aggiungerli, specificali come MavenReference nel tipo di dati CustomArtifactsConfiguration, come mostrato negli esempi seguenti.

Il aws-msk-iam-auth connettore è il connettore da utilizzare con Amazon MSK che include la funzionalità di autenticazione automatica. IAM

Nota

Le versioni dei connettori mostrate nell'esempio seguente sono le uniche supportate.

For the Kinesis connector:

"CustomArtifactsConfiguration": [{
"ArtifactType": "DEPENDENCY_JAR",            
   "MavenReference": {
"GroupId": "org.apache.flink",

      "ArtifactId": "flink-sql-connector-kinesis",
      "Version": "1.15.4"

   }      
}]

For authenticating with AWS MSK through AWS IAM:

"CustomArtifactsConfiguration": [{
"ArtifactType": "DEPENDENCY_JAR",            
   "MavenReference": {
"GroupId": "software.amazon.msk",
      "ArtifactId": "aws-msk-iam-auth",
      "Version": "1.1.6"
   }      
}]
            
For the Apache Kafka connector:  

"CustomArtifactsConfiguration": [{
"ArtifactType": "DEPENDENCY_JAR",            
   "MavenReference": {
"GroupId": "org.apache.flink",

      "ArtifactId": "flink-connector-kafka",
      "Version": "1.15.4"

   }      
}]

Per aggiungere questi connettori a un notebook esistente, usa l'UpdateApplicationAPIoperazione e specificali come MavenReference nel tipo di CustomArtifactsConfigurationUpdate dati.

Nota

È possibile failOnError impostare su true per il flink-sql-connector-kinesis connettore nella tabellaAPI.

Aggiungi dipendenze e connettori personalizzati

Per utilizzare il AWS Management Console per aggiungere una dipendenza o un connettore personalizzato al tuo notebook Studio, procedi nel seguente modo:

  1. Carica il file del connettore personalizzato in Amazon S3.

  2. In AWS Management Console, scegli l'opzione di creazione personalizzata per creare il tuo notebook Studio.

  3. Segui il flusso di lavoro per la creazione del notebook Studio fino alla fase Configurazioni.

  4. Nella sezione Connettori personalizzati, scegli Aggiungi connettore personalizzato.

  5. Specifica la posizione Amazon S3 della dipendenza o del connettore personalizzato.

  6. Scegli Save changes (Salva modifiche).

Per aggiungere una dipendenza JAR o un connettore personalizzato quando crei un nuovo notebook Studio utilizzando il CreateApplicationAPI, specifica la posizione Amazon S3 della JAR dipendenza o del connettore personalizzato nel CustomArtifactsConfiguration tipo di dati. Per aggiungere una dipendenza o un connettore personalizzato a un notebook Studio esistente, richiama l'UpdateApplicationAPIoperazione e specifica la posizione Amazon S3 della JAR dipendenza o del connettore personalizzato nel tipo di dati. CustomArtifactsConfigurationUpdate

Nota

Quando includi una dipendenza o un connettore personalizzato, devi inserire anche tutte le relative dipendenze transitive non incluse al suo interno.