Uma empresa construiu um pipeline de ingestão de dados que usa o Amazon Kinesis Data Firehose para enviar transações de vendas de e-commerce para o Amazon OpenSearch Service. O intervalo de buffer do Firehose está configurado para 60 segundos. Um modelo linear do OpenSearch produz previsões de vendas em tempo real que aparecem em um painel do OpenSearch. A empresa exige latência de subsegundo para o painel em tempo real. Qual mudança arquitetônica atenderá a esse requisito?

A opção correta é "Definir o stream do Firehose para usar buffer zero e ajustar o tamanho do lote usado por PutRecordBatch." O Amazon Kinesis Data Firehose introduz latência devido ao seu mecanismo de buffer, que acumula dados antes de entregá-los. Para alcançar latência de subsegundo, é crucial minimizar esse buffer. Configurar o buffer para zero e otimizar o tamanho do lote de PutRecordBatch permite que os dados sejam enviados ao OpenSearch Service quase instantaneamente. As outras opções estão incorretas porque: "Substituir o stream do Firehose por uma tarefa do AWS DataSync e habilitar consumidores com fan-out aprimorado" não é apropriado para ingestão de dados em tempo real para o OpenSearch Service; o DataSync é para transferência de dados em massa entre armazenamentos. "Aumentar o intervalo de buffer do Firehose de 60 segundos para 120 segundos" aumentaria a latência, o oposto do requisito. "Substituir o stream do Firehose por uma fila do Amazon SQS" introduziria uma arquitetura de fila que, embora assíncrona, não é otimizada para a ingestão direta e de baixa latência de streams de dados para o OpenSearch Service como o Kinesis Data Firehose.