Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.
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
. setExclusiveStartStreamName
Metode 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.