Bir şirket, e-ticaret satış işlemlerini Amazon OpenSearch Service'e göndermek için Amazon Kinesis Data Firehose kullanan bir veri alım hattı kurdu. Firehose arabellek aralığı 60 saniyeye ayarlanmıştır. Bir OpenSearch doğrusal modeli, bir OpenSearch kontrol panelinde görünen gerçek zamanlı satış tahminleri üretir. Şirket, gerçek zamanlı kontrol paneli için milisaniyenin altında gecikme süresi gerektiriyor. Bu gereksinimi hangi mimari değişikliği karşılayacaktır?

Doğru cevap, Firehose akışını sıfır arabellek kullanacak şekilde ayarlamak ve PutRecordBatch tarafından kullanılan toplu iş boyutunu ayarlamaktır. Amazon Kinesis Data Firehose, verileri hedefe teslim etmeden önce arabelleğe alır. Mevcut 60 saniyelik arabellek aralığı, milisaniyenin altında gecikme süresi gereksinimini karşılamaz. Arabellek aralığını sıfıra ayarlamak, verilerin Firehose'a ulaştığı anda OpenSearch'e gönderilmesini sağlayarak gecikmeyi önemli ölçüde azaltır. PutRecordBatch toplu iş boyutunu ayarlamak, veri alımının verimliliğini daha da optimize edebilir. Diğer seçenekler neden yanlış: Firehose akışını bir AWS DataSync göreviyle değiştirmek ve gelişmiş fan-out tüketicilerini etkinleştirmek, DataSync'in birincil kullanım durumu olmadığı ve gelişmiş fan-out'un Kinesis Data Streams için geçerli olduğu için uygun değildir. Firehose arabellek aralığını 60 saniyeden 120 saniyeye çıkarmak, gecikmeyi artıracak ve milisaniyenin altında gecikme gereksinimini karşılamayacaktır. Firehose akışını bir Amazon SQS kuyruğuyla değiştirmek, SQS'in doğrudan OpenSearch'e veri göndermek için tasarlanmamış bir mesajlaşma hizmeti olması nedeniyle uygun değildir ve ek entegrasyon katmanları gerektirecektir.