Kinesis Data Streams

Gerçek Zamanlı Verileri toplar.

Kinesis Data Streams Kapalı Diyagrarm
Kinesis Data Streams Açık Diyagram
  • Veriler Shard adı verilen kümelerde tutulur.

  • Shard’da tutulan benzersiz verilere record yani kayıt denilir.

  • Her kayıt sequence number yani shard’a giriş sırasını belirleyen değer, partition key yani basitçe hangi shard’da bulunduğunu belirten değer ve data blob yani gerçek içerikten oluşur.

  • Record maksimum 1MB boyutunda olabilir.

  • 1 Shard saniyede 1MB’a veya 1.000 PUT işlemine kadar depolama ve saniyede 2MB hızında okunma kapasitesine sahiptir.

  • Shard’lar otomatik olarak büyüyüp küçülmez ve kaç shard kullanacağınızı başlangıçta sizin belirlemeniz gerekir.

circle-info

Kinesis Data Streams'te verilerin hedefi çokludur yani birden fazla consumera hedef teslimi yapılır. SQS'te ise hedefler sadece tekil servislerdir.

  • Veri saklama süresi en fazla 365 güne kadar ayarlanabilir

  • Tüketiciler (consumers), verileri yeniden işleyebilir (replay edebilir)

  • Veriler süresi dolana kadar Kinesis’ten silinemez

  • 1MB’a kadar veri desteklenir (yaygın kullanım senaryosu: çok sayıda küçük gerçek zamanlı veri)

  • Aynı Partition ID ile gönderilen veriler için sıra garantisi vardır

  • KMS ile at-rest (bekleme hâlindeki) şifreleme, HTTPS ile in-flight (taşınırken) şifreleme desteği bulunur

  • Kinesis Producer Library (KPL), optimize üretici uygulamaları yazmak için kullanılır

  • Kinesis Client Library (KCL), optimize tüketici uygulamaları yazmak için kullanılır.

Kapasite Modları:

Provisioned Mode (Önceden Tahsisli Mod):

  • Shard sayısını kendin belirlersin

  • Her shard: saniyede 1 MB veri girişi veya 1000 kayıt (record) alabilir

  • Her shard: saniyede 2 MB veri çıkışı sağlar

  • Shard sayısını elle artırıp azaltman gerekir

  • Saatlik olarak her shard için ücretlendirilirsin


On-Demand Mode (İsteğe Bağlı Mod):

  • Kapasiteyi önceden ayarlamana gerek yoktur

  • Varsayılan kapasite: saniyede 4 MB veri girişi veya 4000 kayıt

  • Son 30 gündeki en yüksek veri kullanımına göre otomatik ölçeklenir

  • Stream başına saatlik ve GB başına veri giriş/çıkış üzerinden ücretlendirilirsin

Last updated