Funzionalità di Servizio gestito da Amazon per Apache Flink

Servizio gestito da Amazon per Apache Flink include librerie open source come Apache Flink, Apache Beam, Apache Zeppelin, AWS SDK e integrazioni dei servizi AWS. Apache Flink è un framework e motore per la creazione di applicazioni in streaming altamente disponibili e precise. Apache Beam è un modello unificato per la definizione di applicazioni di streaming ed elaborazione dei dati in batch eseguite su più motori di runtime. Gli SDK AWS aiutano a semplificare la codifica per numerosi servizi AWS fornendo API nel linguaggio preferito e include librerie, esempi di codici e documentazione di AWS. 

Il servizio gestito da Amazon per Apache Flink supporta le API di Flink in Java, Scala, Python e SQL specializzate per differenti casi d'uso, tra cui elaborazione di eventi stateful, ETL (extract, transform, and load) in streaming e analisi in tempo reale. Con operatori e funzionalità di analisi predefiniti, è possibile creare un'applicazione di streaming Apache Flink in poche ore anziché mesi e le librerie sono estensibili, quindi è possibile eseguire l'elaborazione in tempo reale per un'ampia varietà di casi d'uso.

È possibile configurare e integrare un'origine dati o una destinazione con pochissimo codice. Utilizza le librerie del servizio gestito da Amazon per Apache Flink per l'integrazione con i seguenti servizi AWS:  

• Amazon S3
• Amazon MSK
• Servizio OpenSearch di Amazon
• Amazon DynamoDB
• Flusso di dati Amazon Kinesis
• Amazon Kinesis Data Firehose
• Amazon CloudWatch
• Registro degli schemi di AWS Glue

Oltre alle integrazioni AWS, le librerie del servizio gestito da Amazon per Apache Flink includono più di 40 connettori Apache Flink e la possibilità di creare integrazioni personalizzate. Con un paio di linee di codice in più, è possibile modificare il comportamento di ogni integrazione con funzionalità avanzate. Inoltre, è possibile creare integrazioni personalizzate anche usando un set di primitive di Apache Flink che consentono di leggere e scrivere su file, directory, socket o altre origini a cui è possibile accedere da Internet.

Grazie al servizio gestito da Amazon per Apache Flink è possibile creare applicazioni i cui record elaborati influiscono sui risultati esattamente una sola volta e vengono indicati come una elaborazione esatta. Anche nel caso di interruzione di un'applicazione, ad esempio per manutenzione interna o per un aggiornamento avviato dall'utente, il servizio garantisce che tutti i dati vengano elaborati e che non ci siano duplicati.

Il servizio archivia calcoli precedenti e in corso nella memoria dell’applicazione in esecuzione. Confronta risultati in tempo reale e precedenti relativi a qualsiasi periodo e ottieni il ripristino rapido durante le interruzioni dell’applicazione. Lo stato è sempre crittografato e salvato in modo incrementale nella memoria di applicazioni in esecuzione.

Crea ed elimina backup durevoli delle applicazioni attraverso una semplice chiamata API. Ripristina le tue applicazioni dall'ultimo backup immediatamente dopo un'interruzione oppure ripristina l'applicazione a una versione precedente. 

Il servizio gestito da Amazon per Apache Flink supporta algoritmi di machine learning (ML). È possibile creare applicazioni in tempo reale per la classificazione, il clustering, la valutazione, i suggerimenti di ingegneria delle funzionalità, le regressioni e le statistiche. 

Il servizio gestito da Amazon per Apache Flink è compatibile con il registro degli schemi di AWS Glue. Il registro degli schemi aiuta a migliorare la qualità dei dati e a proteggerti da modifiche impreviste utilizzando controlli di compatibilità che regolano l'evoluzione dello schema per i carichi di lavoro del servizio gestito da Amazon per Apache Flink connessi ad Apache Kafka, Amazon MSK o flussi di dati Amazon Kinesis, come connettore di origine o sink.