DynamoDB Streams e Apache Flink - Amazon DynamoDB

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

DynamoDB Streams e Apache Flink

Puoi utilizzare i record di Amazon DynamoDB Streams con Apache Flink. Con Amazon Managed Service per Apache Flink, puoi trasformare e analizzare i dati di streaming in tempo reale utilizzando Apache Flink. Apache Flink è un framework di elaborazione di flussi open source per l'elaborazione di dati in tempo reale. Il connettore Amazon DynamoDB Streams per Apache Flink semplifica la creazione e la gestione dei carichi di lavoro Apache Flink e consente di integrare applicazioni con altri. Servizi AWS

Amazon Managed Service for Apache Flink ti aiuta a creare rapidamente applicazioni di elaborazione dei end-to-end flussi per l'analisi dei log, l'analisi dei clickstream, l'Internet of Things (IoT), la tecnologia pubblicitaria, i 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'interrogazione interattiva dei flussi di dati. Per ulteriori informazioni sulla scrittura su Apache Flink da Amazon DynamoDB Streams, consulta Amazon DynamoDB Streams Connector.

Amazon DynamoDB Streams supporta ShardFilter il parametro nell'API per trovare un DescribeStream sottoinsieme di shard. Specificando uno shard principale nella richiesta, DynamoDB Streams restituirà i suoi shard secondari immediati. È possibile utilizzare il ShardFilter parametro per scoprire rapidamente gli shard secondari dopo la chiusura di uno shard principale, rendendo le applicazioni di elaborazione dei flussi più reattive ed economiche.

Amazon Managed Service for Apache Flink supporta il ShardFilter parametro durante la lettura da DynamoDB Streams. Per utilizzare questa funzionalità, devi richiedere l'accesso a una versione speciale del connettore Flink che include il supporto. ShardFilter Per iniziare, apri una richiesta di supporto nel AWS Support Center e richiedi l'accesso a questi file binari. Per ulteriori informazioni sull'utilizzo di DynamoDB Streams con Apache Flink, consulta la DynamoDB Developer Guide. Lettura ed elaborazione di un flusso