AWS SDK を使用した Amazon Data Firehose への書き込み - Amazon Data Firehose

Amazon Data Firehose は、以前は Amazon Kinesis Data Firehose と呼ばれていました。

翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。

AWS SDK を使用した Amazon Data Firehose への書き込み

Amazon Data Firehose API を使用して、AWSSDK for Java 、.NET 、Node.js https://aws.amazon.com/sdk-for-javascript/Python 、または Ruby を使用して Firehose ストリームにデータを送信できます。Amazon Data Firehose を初めて使用する場合は、「」で説明されている概念と用語に慣れるまで少し時間がかかりますAmazon Data Firehose とは。詳細については、「アマゾン ウェブ サービスを使用した開発の開始」を参照してください。

これらのサンプルは、すべての例外を確認しているわけではなく、すべてのセキュリティやパフォーマンスの側面を考慮しているわけでもない点で、本稼働環境に使用できるコードを表すものではありません。

Amazon Data Firehose API には、Firehose ストリームにデータを送信するための 2 つのオペレーション PutRecordと がありますPutRecordBatch。 は 1 回の呼び出しで 1 つのデータレコードPutRecord()を送信し、1 回の呼び出しで複数のデータレコードを送信PutRecordBatch()できます。

を使用した単一書き込みオペレーション PutRecord

データを入力するには、Firehose ストリーム名とバイトバッファ (<=1000 KB) のみが必要です。Amazon Data Firehose はファイルを Amazon S3 にロードする前に複数のレコードをバッチ処理するため、レコード区切り文字を追加することもできます。一度に 1 つのレコードを 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 Operations」の関連トピックを参照してください。

を使用したバッチ書き込みオペレーション 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 Operations」の関連トピックを参照してください。