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 i connettori per spostare i dati in Managed Service for Apache Flink con l'API DataStream
Nell' DataStream API Amazon Managed Service for Apache Flink, i connettori sono componenti software che spostano i dati da e verso un'applicazione Managed Service for Apache Flink. I connettori sono integrazioni flessibili che consentono di leggere file e directory. I connettori sono costituiti da moduli completi per l'interazione con i servizi Amazon e i sistemi di terze parti.
I tipi di connettori comprendono:
Aggiungi sorgenti di dati in streaming: invio di dati all'applicazione da un flusso di dati, un file o un'altra origine dati Kinesis.
Scrivi dati utilizzando i lavandini: invia dati dall'applicazione a un flusso di dati Kinesis, a un flusso Firehose o a un'altra destinazione di dati.
Usa I/O asincrono: fornisce l'accesso asincrono a un'origine dati (ad esempio, un database) per arricchire gli eventi di flusso.
Connettori disponibili
Il framework Apache Flink contiene connettori per l'accesso ai dati da vari tipi di origini. Per informazioni sui connettori disponibili nel framework Apache Flink, consulta Connettori
avvertimento
Se hai applicazioni in esecuzione su Flink 1.6, 1.8, 1.11 o 1.13 e desideri eseguirle nelle regioni del Medio Oriente (Emirati Arabi Uniti), Asia Pacifico (Hyderabad), Israele (Tel Aviv), Europa (Zurigo), Medio Oriente (Emirati Arabi Uniti), Asia Pacifico (Melbourne) o Asia Pacifico (Giacarta), potresti dover ricostruire l'archivio delle applicazioni con un connettore aggiornato o eseguire l'aggiornamento a Flink 1.18.
I connettori Apache Flink sono archiviati nei propri archivi open source. Se stai eseguendo l'aggiornamento alla versione 1.18 o successiva, devi aggiornare le tue dipendenze. Per accedere al repository per i connettori Apache Flink, consulta. AWS flink-connector-aws
Il precedente sorgente Kinesis non org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumer è più disponibile e potrebbe essere rimosso con le future release di Flink. Utilizzate invece Kinesis Source
Non esiste alcuna compatibilità a livello di stato tra FlinkKinesisConsumer eKinesisStreamsSource. Per i dettagli, consulta Migrazione dei job esistenti al nuovo Kinesis Streams
Di seguito sono riportate le linee guida consigliate:
| Versione di Flink | Connettore usato | Risoluzione |
|---|---|---|
| 1.19, 1.20 | Sorgente Kinesis |
Quando esegui l'aggiornamento a Managed Service for Apache Flink versione 1.19 e 1.20, assicurati di utilizzare il connettore sorgente Kinesis Data Streams più recente. Deve essere una qualsiasi versione 5.0.0 o successiva. Per ulteriori informazioni, consulta Amazon Kinesis Data Streams Connector |
| 1.19, 1.20 | Lavello Kinesis |
Quando esegui l'aggiornamento a Managed Service for Apache Flink versione 1.19 e 1.20, assicurati di utilizzare il connettore sink Kinesis Data Streams più recente. Deve essere una qualsiasi versione 5.0.0 o successiva. Per ulteriori informazioni, vedere Kinesis Streams |
| 1.19, 1.20 | Sorgente DynamoDB Streams |
Quando esegui l'aggiornamento a Managed Service for Apache Flink versione 1.19 e 1.20, assicurati di utilizzare il connettore sorgente DynamoDB Streams più recente. Deve essere una qualsiasi versione 5.0.0 o successiva. Per ulteriori informazioni, consulta Amazon DynamoDB Connector |
| 1.19, 1.20 | Lavandino DynamoDB | Quando esegui l'aggiornamento a Managed Service for Apache Flink versione 1.19 e 1.20, assicurati di utilizzare il connettore sink DynamoDB più recente. Deve essere una qualsiasi versione 5.0.0 o successiva. Per ulteriori informazioni, consulta Amazon DynamoDB Connector |
| 1.19, 1.20 | Lavandino Amazon SQS |
Quando esegui l'aggiornamento a Managed Service for Apache Flink versione 1.19 e 1.20, assicurati di utilizzare il connettore sink di Amazon SQS più recente. Deve essere una qualsiasi versione 5.0.0 o successiva. Per ulteriori informazioni, consulta Amazon SQS Sink. |
| 1.19, 1,20 | Servizio gestito Amazon per Prometheus Sink |
Quando esegui l'aggiornamento a Managed Service for Apache Flink versione 1.19 e 1.20, assicurati di utilizzare il connettore sink di Amazon Managed Service for Prometheus più recente. Deve essere una qualsiasi versione 1.0.0 o successiva. Per ulteriori informazioni, vedere Prometheus |
