Menulis ke Amazon Data Firehose dengan SDK AWS

Anda dapat menggunakan Amazon Data Firehose API untuk mengirim data ke aliran Firehose menggunakan SDK for AWS Java, .NET, Node.js, Python, atau Ruby. Jika Anda baru mengenal Amazon Data Firehose, luangkan waktu untuk membiasakan diri dengan konsep dan terminologi yang disajikan. Apa itu Amazon Data Firehose? Untuk informasi selengkapnya, lihat Mulai Pengembangan dengan Amazon Web Services.

Contoh-contoh ini tidak mewakili kode siap produksi, karena contoh ini tidak memeriksa semua kemungkinan pengecualian, atau memperhitungkan semua kemungkinan pertimbangan keamanan atau performa.

Amazon Data Firehose API menawarkan dua operasi untuk mengirim data ke aliran Firehose Anda: dan. PutRecordPutRecordBatch PutRecord()mengirim satu catatan data dalam satu panggilan dan PutRecordBatch() dapat mengirim beberapa catatan data dalam satu panggilan.

Operasi Tulis Tunggal Menggunakan PutRecord

Menempatkan data hanya membutuhkan nama aliran Firehose dan buffer byte (<=1000 KB). Karena Amazon Data Firehose mengumpulkan beberapa catatan sebelum memuat file ke Amazon S3, Anda mungkin ingin menambahkan pemisah rekaman. Untuk memasukkan data satu rekaman pada satu waktu ke aliran Firehose, gunakan kode berikut:

PutRecordRequest putRecordRequest = new PutRecordRequest();
putRecordRequest.setDeliveryStreamName(deliveryStreamName);

String data = line + "\n";

Record record = new Record().withData(ByteBuffer.wrap(data.getBytes()));
putRecordRequest.setRecord(record);

// Put record into the DeliveryStream
firehoseClient.putRecord(putRecordRequest);

Untuk konteks kode lainnya, lihat kode contoh yang disertakan dalam AWS SDK. Untuk informasi tentang sintaks permintaan dan respons, lihat topik yang relevan di Operasi API Firehose.

Operasi Batch Write Menggunakan PutRecordBatch

Menempatkan data hanya memerlukan nama aliran Firehose dan daftar catatan. Karena Amazon Data Firehose mengumpulkan beberapa catatan sebelum memuat file ke Amazon S3, Anda mungkin ingin menambahkan pemisah rekaman. Untuk memasukkan catatan data dalam batch ke aliran Firehose, gunakan kode berikut:

PutRecordBatchRequest putRecordBatchRequest = new PutRecordBatchRequest();
putRecordBatchRequest.setDeliveryStreamName(deliveryStreamName);
putRecordBatchRequest.setRecords(recordList);

// Put Record Batch records. Max No.Of Records we can put in a
// single put record batch request is 500
firehoseClient.putRecordBatch(putRecordBatchRequest);

recordList.clear();

Untuk konteks kode lainnya, lihat kode contoh yang disertakan dalam AWS SDK. Untuk informasi tentang sintaks permintaan dan respons, lihat topik yang relevan di Operasi API Firehose.