Langkah 1: Membuat Stream Data

Pada langkah pertamaTutorial: Memproses Data Stock Real-Time Menggunakan KPL dan KCL 1.x, Anda membuat aliran yang akan Anda gunakan dalam langkah berikutnya.

Untuk membuat aliran

1. Masuk ke AWS Management Console dan buka konsol Kinesis di https://console.aws.amazon.com/kinesis.

2. Pilih Data Streams (Aliran Data) di panel navigasi.

3. Di bilah navigasi, perluas pemilih Region dan pilih Region.

4. Pilih Buat aliran Kinesis.

5. Masukkan nama untuk streaming Anda (misalnya,StockTradeStream).

6. Masukkan 1 jumlah pecahan, tetapi tinggalkan Perkirakan jumlah pecahan yang Anda perlukan untuk diciutkan.

7. Pilih Buat aliran Kinesis.

Pada halaman daftar aliran Kinesis, status streaming Anda adalah CREATING saat streaming sedang dibuat. Saat streaming siap digunakan, status akan berubah menjadiACTIVE. Pilih nama streaming Anda. Di halaman yang muncul, tab Detail menampilkan ringkasan konfigurasi aliran Anda. Bagian Monitoring menampilkan informasi pemantauan untuk aliran.

Informasi Tambahan Tentang Pecahan

Saat Anda mulai menggunakan Kinesis Data Streams di luar tutorial ini, Anda mungkin perlu merencanakan proses pembuatan stream dengan 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 di siang hari (waktu Timur) dan perkiraan permintaan harus diambil sampel dari waktu itu. Anda kemudian memiliki pilihan untuk menyediakan permintaan maksimum yang diharapkan, atau skala aliran Anda naik dan turun dalam menanggapi fluktuasi permintaan.

Shard adalah unit kapasitas throughput. Pada halaman Create Kinesis stream, perluas Perkirakan jumlah pecahan yang Anda perlukan. Masukkan ukuran rekaman rata-rata, catatan maksimum yang ditulis per detik, dan jumlah aplikasi yang dikonsumsi, menggunakan panduan 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.

Max catatan ditulis

Memperhitungkan 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 mengonsumsi

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 shard Anda saat ini, Anda mungkin perlu mengirimkan permintaan untuk meningkatkan batas tersebut sebelum Anda dapat membuat stream dengan jumlah pecahan tersebut. Untuk meminta peningkatan batas shard Anda, gunakan formulir Batas Aliran Data Kinesis. Untuk informasi selengkapnya tentang aliran dan pecahan, lihat. Membuat dan Mengelola Streaming

Langkah Selanjutnya

Langkah 2: Buat Kebijakan dan Pengguna IAM