ben okur ve Kinesis Müşteri Kütüphanesi (KCL) kullanarak bir AWS Kinesis Çayı'nın olayları işleyen bir uygulama üzerinde çalışıyorum KCL

Question

içindeki Kinesis Olaylar gönderdi. Ben olay yapımcı tarafı nedenle KinesisAsyncClient etkinlikleri göndermek için kullanılan bir beklemeye maruz istemiyoruz. Ancak benim olay işleme düzgün çalışması için sırayla, benim yapımcı tarafındaki "Ben putRecordAsync denilen düzen" de eşitler işlemek gerekir. Bu bilgiler her Kinesis Record içinde bir zaman damgası alanı olarak kullanılabilir. engelleme senkron Kinesis istemcisi kullanmak için geçiş yapmasını Kenara

, başka bir çözüm verimli akış etkinliklerini sıralamak mümkündür var mı? Sipariş önemliyse

Answer 1

, değil zaman uyumsuz istemci kullanırız.

Async istemcisi, aynı çağrıları yapmak için kapakların altındaki bir iş parçacığı havuzunu kullanır - çok iş parçacıklı olduğundan, bu iş parçacıklarının yürütme sırasını garanti edemezsiniz ve sonuç olarak, bunlar üzerinde denetiminiz yoktur. Kayıtlar Kinesis tarafından alınır.

Şimdi, gecikme gerçekten üretici için bir sorun olup olmadığını:

1. Eğer mümkünse (yerine PutRecord ait) PutRecords aradığınız emin olun - bu kesinlikle size bazı ağ yuvarlak gezileri kaydeder.

2. İstemciyi doğrudan çağırmak yerine, sıralı kayıtları yerel bir sıraya koyun ve PutRecords'ı çağırmak için bu sıradan düzenli olarak yoklamak için bir arka plan iş parçacığı kullanın. akılda tutulması gereken

gereken diğer noktalar - Bu boşaltmak yakın işlemdeki kuyruğunu tutmak için yeterince hızlı değilse, o size koyarak birden konuları gerekir yeterince büyük bir veri hacmini var belirtir veri ve artık kesin siparişiniz yok. Bu durumda, sıra numaralarını kayıt numaranıza kaydetmenizi öneriyorum, böylece gerekirse tüketici tarafında yeniden sipariş verebilirsiniz (bu durumda KSSS'ler yerine başlangıç ​​noktası olarak SQS'yi düşünün)