Flussi DynamoDB e Apache Flink

È possibile utilizzare i record dei flussi Amazon DynamoDB con Apache Flink. Con il Servizio gestito da Amazon per Apache Flink è possibile trasformare e analizzare i dati in streaming in tempo reale con Apache Flink. Apache Flink è un framework di elaborazione di flussi open source per l’elaborazione di dati in tempo reale. Il connettore dei flussi Amazon DynamoDB per Apache Flink semplifica la creazione e la gestione dei carichi di lavoro Apache Flink e consente di integrare le applicazioni con altri Servizi AWS.

Il Servizio gestito da Amazon per Apache Flink aiuta a creare rapidamente applicazioni di elaborazione di flussi end-to-end per analisi di log, analisi di clickstream, Internet delle cose (IoT), tecnologia pubblicitaria, giochi e altro ancora. I quattro casi d’uso più comuni sono lo streaming extract-transform-load (ETL), le applicazioni basate sugli eventi, l’analisi reattiva in tempo reale e l’esecuzione di query interattiva dei flussi di dati. Per ulteriori informazioni sulla scrittura in Apache Flink dai flussi Amazon DynamoDB, consulta Amazon DynamoDB Streams Connector.

Utilizzo del parametro ShardFilter con il connettore dei flussi DynamoDB per Apache Flink

I flussi Amazon DynamoDB supportano il parametro ShardFilter nell’API DescribeStream per trovare un sottoinsieme di shard. Specificando uno shard principale nella richiesta, i flussi DynamoDB restituiranno i relativi shard secondari immediati. È possibile usare il parametro ShardFilter per individuare rapidamente gli shard secondari dopo la chiusura di uno shard principale, rendendo le applicazioni di elaborazione dei flussi più reattive e convenienti.

Il servizio gestito da Amazon per Apache Flink supporta il parametro ShardFilter durante la lettura dai flussi DynamoDB. Per utilizzare questa funzionalità, è necessario richiedere l’accesso a una versione speciale del connettore Flink che include il supporto ShardFilter. Per iniziare, apri una richiesta di supporto nel Centro di supporto AWS e richiedi l’accesso a questi file binari. Per ulteriori informazioni sull’utilizzo dei flussi DynamoDB con Apache Flink, consulta Lettura ed elaborazione di un flusso nella Guida per gli sviluppatori di DynamoDB.