Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.
Buat aliran data
Pada langkah pertamaTutorial: Memproses data stok real-time menggunakan KPL dan KCL 1.x, Anda membuat aliran yang akan Anda gunakan dalam langkah selanjutnya.
Untuk membuat aliran
-
Pilih Data Streams (Aliran Data) di panel navigasi.
-
Di bilah navigasi, perluas pemilih Wilayah dan pilih Wilayah.
-
Pilih Buat aliran Kinesis.
-
Masukkan nama untuk streaming Anda (misalnya,
StockTradeStream). -
Masukkan
1untuk jumlah pecahan, tetapi tetap Perkirakan jumlah pecahan yang Anda perlukan untuk diciutkan. -
Pilih Buat aliran Kinesis.
Pada halaman daftar Kinesis streams, status streaming Anda adalah CREATING saat aliran sedang dibuat. Saat aliran siap digunakan, statusnya berubah menjadiACTIVE. Pilih nama streaming Anda. Di halaman yang muncul, tab Detail menampilkan ringkasan konfigurasi aliran Anda. Bagian Pemantauan menampilkan informasi pemantauan untuk aliran.
Informasi tambahan tentang pecahan
Ketika Anda mulai menggunakan Kinesis Data Streams di luar tutorial ini, Anda mungkin perlu merencanakan proses pembuatan aliran lebih hati-hati. Anda harus merencanakan permintaan maksimum yang diharapkan saat Anda menyediakan pecahan. Dengan menggunakan skenario ini sebagai contoh, lalu lintas perdagangan pasar saham AS memuncak pada siang hari (waktu Timur) dan perkiraan permintaan harus diambil sampelnya dari waktu itu. Anda kemudian memiliki pilihan untuk menyediakan permintaan maksimum yang diharapkan, atau meningkatkan aliran Anda ke atas dan ke bawah sebagai respons terhadap fluktuasi permintaan.
Shard adalah unit kapasitas throughput. Pada halaman aliran Create Kinesis, perluas Perkirakan jumlah pecahan yang Anda perlukan. Masukkan ukuran catatan rata-rata, catatan maksimum yang ditulis per detik, dan jumlah aplikasi yang dikonsumsi, menggunakan pedoman berikut:
- Ukuran rekor rata-rata
-
Perkiraan ukuran rata-rata yang dihitung dari catatan Anda. Jika Anda tidak mengetahui nilai ini, gunakan perkiraan ukuran rekaman maksimum untuk nilai ini.
- Catatan Max ditulis
-
Pertimbangkan jumlah entitas yang menyediakan data dan perkiraan jumlah catatan per detik yang dihasilkan oleh masing-masing. Misalnya, jika Anda mendapatkan data perdagangan saham dari 20 server perdagangan dan masing-masing menghasilkan 250 perdagangan per detik, jumlah total perdagangan (catatan) per detik adalah 5000/detik.
- Jumlah aplikasi yang dikonsumsi
-
Jumlah aplikasi yang secara independen membaca dari aliran untuk memproses aliran dengan cara yang berbeda dan menghasilkan output yang berbeda. Setiap aplikasi dapat memiliki beberapa instance yang berjalan pada mesin yang berbeda (yaitu, dijalankan dalam cluster) sehingga dapat mengikuti aliran volume tinggi.
Jika perkiraan jumlah pecahan yang ditampilkan melebihi batas pecahan Anda saat ini, Anda mungkin perlu mengirimkan permintaan untuk meningkatkan batas tersebut sebelum Anda dapat membuat aliran dengan jumlah pecahan tersebut. Untuk meminta peningkatan batas pecahan, gunakan formulir Batas Aliran Data Kinesis
Langkah selanjutnya
Buat IAM kebijakan dan pengguna
