Daftar aliran

Stream dicakup ke AWS akun yang terkait dengan AWS kredensil yang digunakan untuk membuat instance klien Kinesis Data Streams dan juga ke Wilayah yang ditentukan untuk klien. Sebuah AWS akun dapat memiliki banyak aliran aktif pada satu waktu. Anda dapat mencantumkan aliran Anda di konsol Kinesis Data Streams, atau secara terprogram. Kode di bagian ini menunjukkan cara membuat daftar semua aliran untuk AWS akun Anda.

ListStreamsRequest listStreamsRequest = new ListStreamsRequest();
listStreamsRequest.setLimit(20); 
ListStreamsResult listStreamsResult = client.listStreams(listStreamsRequest);
List<String> streamNames = listStreamsResult.getStreamNames();

Contoh kode ini pertama kali membuat instance baru ListStreamsRequest dan memanggil setLimit metodenya untuk menentukan bahwa maksimum 20 aliran harus dikembalikan untuk setiap panggilan kelistStreams. Jika Anda tidak menentukan nilai untuksetLimit, Kinesis Data Streams mengembalikan sejumlah aliran kurang dari atau sama dengan nomor di akun. Kode kemudian diteruskan listStreamsRequest ke listStreams metode klien. Nilai kembali listStreams disimpan dalam ListStreamsResult objek. Kode memanggil getStreamNames metode pada objek ini dan menyimpan nama aliran yang dikembalikan dalam streamNames daftar. Perhatikan bahwa Kinesis Data Streams mungkin mengembalikan aliran lebih sedikit daripada yang ditentukan oleh batas yang ditentukan meskipun ada lebih banyak aliran daripada yang ada di akun dan Wilayah. Untuk memastikan bahwa Anda mengambil semua aliran, gunakan getHasMoreStreams metode seperti yang dijelaskan dalam contoh kode berikutnya.

while (listStreamsResult.getHasMoreStreams()) 
{
    if (streamNames.size() > 0) {
      listStreamsRequest.setExclusiveStartStreamName(streamNames.get(streamNames.size() - 1));
    }
    listStreamsResult = client.listStreams(listStreamsRequest);
    streamNames.addAll(listStreamsResult.getStreamNames());
}

Kode ini memanggil getHasMoreStreams metode listStreamsRequest untuk memeriksa apakah ada aliran tambahan yang tersedia di luar yang dikembalikan dalam panggilan awal kelistStreams. Jika demikian, kode memanggil setExclusiveStartStreamName metode dengan nama aliran terakhir yang dikembalikan dalam panggilan sebelumnya kelistStreams. setExclusiveStartStreamNameMetode ini menyebabkan listStreams panggilan berikutnya dimulai setelah aliran itu. Grup nama aliran yang dikembalikan oleh panggilan itu kemudian ditambahkan ke streamNames daftar. Proses ini berlanjut hingga semua nama aliran dikumpulkan dalam daftar.

Aliran yang dikembalikan oleh listStreams dapat berada di salah satu status berikut:

• CREATING

• ACTIVE

• UPDATING

• DELETING

Anda dapat memeriksa status aliran menggunakan describeStream metode, seperti yang ditunjukkan pada bagian sebelumnya,Buat aliran menggunakan APIs.