Компания создала конвейер приема данных, который использует Amazon Kinesis Data Firehose для отправки транзакций продаж электронной коммерции в Amazon OpenSearch Service. Интервал буферизации Firehose установлен на 60 секунд. Линейная модель OpenSearch создает прогнозы продаж в реальном времени, которые отображаются на панели мониторинга OpenSearch. Компании требуется задержка менее секунды для панели мониторинга в реальном времени. Какое архитектурное изменение позволит достичь этого требования?

Правильный ответ — «Установите для потока Firehose нулевую буферизацию и настройте размер пакета, используемый PutRecordBatch». Kinesis Data Firehose по умолчанию имеет минимальный интервал буферизации 60 секунд или 1 МБ данных, что не соответствует требованию задержки менее секунды. Установка нулевой буферизации (то есть отключение буферизации на основе времени) и настройка размера пакета для PutRecordBatch позволяет отправлять данные в OpenSearch Service практически мгновенно после их получения, обеспечивая задержку менее секунды. Неправильные варианты: «Замените поток Firehose задачей AWS DataSync и включите расширенные потребители fan-out». AWS DataSync предназначен для передачи больших объемов данных между хранилищами, а не для потоковой передачи данных в реальном времени с низкой задержкой. Расширенные потребители fan-out относятся к Kinesis Data Streams, а не к DataSync. «Увеличьте интервал буферизации Firehose с 60 секунд до 120 секунд». Это увеличит, а не уменьшит задержку, что противоречит требованию. «Замените поток Firehose очередью Amazon SQS». Amazon SQS — это служба очередей сообщений, а не потоковая служба для прямой интеграции с OpenSearch Service с низкой задержкой. Использование SQS потребует дополнительной логики для извлечения сообщений и их отправки в OpenSearch, что добавит задержку.