Daftar aliran

Aliran dicakup ke AWS akun yang terkait dengan AWS kredenSIAL yang digunakan untuk membuat instance klien Kinesis Data Streams dan juga ke Wilayah yang ditentukan untuk klien. AWS Akun dapat memiliki banyak aliran aktif pada satu waktu. Anda dapat membuat daftar streaming 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-tama 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 jumlah di akun. Kode kemudian diteruskan listStreamsRequest ke listStreams metode klien. Nilai pengem listStreams balian 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 yang 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 memang setExclusiveStartStreamName gil metode dengan nama aliran terakhir yang dikembalikan dalam panggilan sebelumnya kelistStreams. setExclusiveStartStreamNameMetode ini menyebabkan panggilan berikutnya listStreams dimulai setelah streaming itu. Grup nama aliran yang dikembalikan oleh panggilan itu kemudian ditambahkan ke streamNames daftar. Proses ini berlanjut sampai semua nama aliran dikumpulkan dalam daftar.

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

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