Terjemahan disediakan oleh mesin penerjemah. Jika konten terjemahan yang diberikan bertentangan dengan versi bahasa Inggris aslinya, utamakan versi bahasa Inggris.

Buat aliran menggunakan API

Gunakan langkah-langkah berikut untuk membuat aliran data Kinesis Anda.

Membangun klien Kinesis Data Streams

Sebelum Anda dapat bekerja dengan aliran data Kinesis, Anda harus membangun objek klien. Kode Java berikut membuat instance pembangun klien dan menggunakannya untuk mengatur Wilayah, kredenSIAL, dan konfigurasi klien. Kemudian membangun objek klien.

AmazonKinesisClientBuilder clientBuilder = AmazonKinesisClientBuilder.standard();
        
clientBuilder.setRegion(regionName);
clientBuilder.setCredentials(credentialsProvider);
clientBuilder.setClientConfiguration(config);
        
AmazonKinesis client = clientBuilder.build();

Untuk informasi selengkapnya, lihat Wil ayah dan Titik Akhir Aliran Data Kinesis di. Referensi Umum AWS

Buat streaming

Sekarang setelah Anda membuat klien Kinesis Data Streams, Anda dapat membuat streaming menggunakan konsol atau secara terprogram. Untuk membuat aliran secara terprogram, buat instance CreateStreamRequest objek dan tentukan nama untuk aliran tersebut. Jika Anda ingin menggunakan mode yang disediakan, tentukan jumlah pecahan untuk aliran yang akan digunakan.

Nama aliran mengidentifikasi aliran. Nama dicakup ke AWS akun yang digunakan oleh aplikasi. Itu juga dicakup oleh wilayah. Artinya, dua aliran di dua AWS akun berbeda dapat memiliki nama yang sama, dan dua aliran di AWS akun yang sama tetapi di dua Wilayah yang berbeda dapat memiliki nama yang sama, tetapi bukan dua aliran pada akun yang sama dan di Wilayah yang sama.

Throughput aliran adalah fungsi dari jumlah pecahan. Untuk throughput yang disediakan lebih besar, Anda memerlukan lebih banyak pecahan. Lebih banyak pecahan juga meningkatkan biaya yang AWS dikenakan untuk aliran. Untuk informasi selengkapnya tentang menghitung jumlah pecahan yang sesuai untuk aplikasi Anda, lihatPilih mode yang tepat untuk streaming.

Setelah Anda mengonfigurasi createStreamRequest objek, buat aliran dengan memanggil createStream metode pada klien. Setelah meneleponcreateStream, tunggu streaming mencapai ACTIVE status sebelum melakukan operasi apa pun pada streaming. Untuk memeriksa keadaan aliran, panggil describeStream metode. Namun, describeStream melempar pengecualian jika aliran tidak ada. Oleh karena itu, lampirkan describeStream panggilan di try/catch blok.

client.createStream( createStreamRequest );
DescribeStreamRequest describeStreamRequest = new DescribeStreamRequest();
describeStreamRequest.setStreamName( myStreamName );

long startTime = System.currentTimeMillis();
long endTime = startTime + ( 10 * 60 * 1000 );
while ( System.currentTimeMillis() < endTime ) {
  try {
    Thread.sleep(20 * 1000);
  } 
  catch ( Exception e ) {}
  
  try {
    DescribeStreamResult describeStreamResponse = client.describeStream( describeStreamRequest );
    String streamStatus = describeStreamResponse.getStreamDescription().getStreamStatus();
    if ( streamStatus.equals( "ACTIVE" ) ) {
      break;
    }
    //
    // sleep for one second
    //
    try {
      Thread.sleep( 1000 );
    }
    catch ( Exception e ) {}
  }
  catch ( ResourceNotFoundException e ) {}
}
if ( System.currentTimeMillis() >= endTime ) {
  throw new RuntimeException( "Stream " + myStreamName + " never went active" );
}