SDK를 사용하여 Amazon 데이터 파이어호스에 쓰기 AWS

Amazon Data Firehose API를 사용하면 AWSJava, .NET, Node.js, Python 또는 Ruby용 SDK를 사용하여 Firehose 스트림에 데이터를 전송할 수 있습니다. Amazon Data Firehose를 처음 사용하는 경우 시간을 내어 에 제시된 개념과 용어에 익숙해지십시오. Amazon 데이터 파이어호스란 무엇입니까? 자세한 내용은 Amazon Web Services로 개발 시작을 참조하십시오.

이 예제는 가능한 모든 예외를 확인하지 않거나 가능한 모든 보안 및 성능 고려 사항을 감안하지 않는다는 점에서 프로덕션 지원 코드가 아닙니다.

Amazon Data Firehose API는 Firehose 스트림으로 데이터를 전송하는 두 가지 작업, 즉 및 작업을 제공합니다. PutRecordPutRecordBatch PutRecord()한 번의 호출로 하나의 데이터 레코드를 전송하고 한 번의 호출로 여러 데이터 레코드를 전송할 PutRecordBatch() 수 있습니다.

단일 쓰기 작업: 사용 PutRecord

데이터를 올리려면 Firehose 스트림 이름과 바이트 버퍼 (<=1000KB) 만 필요합니다. Amazon Data Firehose는 파일을 Amazon S3로 로드하기 전에 여러 레코드를 일괄 처리하므로 레코드 구분자를 추가하는 것이 좋습니다. Firehose 스트림에 데이터를 한 번에 하나씩 넣으려면 다음 코드를 사용하세요.

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);

코드 컨텍스트가 더 많은 경우 AWS SDK에 포함된 샘플 코드를 참조하세요. 요청 및 응답 구문에 대한 자세한 내용은 Firehose API 운영의 관련 주제를 참조하십시오.

Batch 쓰기 작업 사용 PutRecordBatch

데이터를 올리려면 Firehose 스트림 이름과 레코드 목록만 필요합니다. Amazon Data Firehose는 파일을 Amazon S3로 로드하기 전에 여러 레코드를 일괄 처리하므로 레코드 구분자를 추가하는 것이 좋습니다. Firehose 스트림에 데이터 레코드를 일괄 처리하려면 다음 코드를 사용하세요.

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();

코드 컨텍스트가 더 많은 경우 AWS SDK에 포함된 샘플 코드를 참조하세요. 요청 및 응답 구문에 대한 자세한 내용은 Firehose API 운영의 관련 주제를 참조하십시오.