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
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.
Utilizzo del ShardFilter parametro con il connettore DynamoDB Streams per Apache Flink
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