ある企業は、Amazon Kinesis Data Firehoseを使用してeコマースの販売トランザクションをAmazon OpenSearch Serviceに送信するデータ取り込みパイプラインを構築しました。Firehoseのバッファ間隔は60秒に設定されています。OpenSearch線形モデルは、OpenSearchダッシュボードに表示されるリアルタイムの販売予測を生成します。同社は、リアルタイムダッシュボードにサブ秒のレイテンシーを求めています。この要件を満たすには、どのアーキテクチャ変更が必要ですか？

サブ秒のレイテンシーを達成するには、Firehoseのバッファリング設定を最小限に抑える必要があります。ゼロバッファリング（または非常に小さいバッファサイズと間隔）に設定することで、データはほぼリアルタイムでOpenSearch Serviceに送信されます。PutRecordBatchのバッチサイズを調整することは、パフォーマンスとコストのバランスを取るために重要です。バッチサイズを小さくするとレイテンシーは減少しますが、API呼び出し回数が増える可能性があります。 AWS DataSyncはデータ移行サービスであり、リアルタイムデータ取り込みには適していません。バッファ間隔を増やすとレイテンシーが悪化します。Amazon SQSはメッセージキューサービスであり、Firehoseのようなストリーミングデータ取り込みサービスとは異なるユースケースに利用されます。