DynamoDB Streams e Apache Flink
É possível consumir registros do Amazon DynamoDB Streams com o Apache Flink. Com o Amazon Managed Service for Apache Flink
O Amazon Managed Service for Apache Flink ajuda você a criar rapidamente aplicações de processamento de fluxos de ponta a ponta para analytics de logs, analytics de clickstream, Internet das Coisas (IoT), tecnologia de anúncios, jogos e muito mais. Os quatro casos de uso mais comuns são extração, transformação e carregamento (ETL) de streaming, aplicações orientadas a eventos, analytics responsivas em tempo real e consultas interativas de fluxos de dados. Para ter mais informações sobre como gravar do Amazon DynamoDB Streams no Apache Flink, consulte Amazon DynamoDB Streams Connector
Usar o parâmetro ShardFilter com o conector DynamoDB Streams para Apache Flink
O Amazon DynamoDB Streams dá suporte ao parâmetro ShardFilter na API DescribeStream para encontrar um subconjunto de fragmentos. Ao especificar um fragmento pai na solicitação, o DynamoDB Streams retornará seus fragmentos filhos imediatos. Você pode usar o parâmetro ShardFilter para descobrir rapidamente fragmentos filhos após o fechamento de um fragmento pai, tornando seus aplicativos de processamento de stream mais responsivos e econômicos.
O Amazon Managed Service for Apache Flink dá suporte ao parâmetro ShardFilter ao ler do DynamoDB Streams. Para usar esse recurso, você deve solicitar acesso a uma versão especial do conector Flink que inclui suporte a ShardFilter. Para começar, abra um caso de suporte no Centro de Suporte da AWS e solicite acesso a esses binários. Para obter mais informações sobre como usar o DynamoDB Streams com Apache Flink, consulte Ler e processar um fluxo no Guia do desenvolvedor do DynamoDB.
