AWS SDK - Amazon Data Firehose
Operaciones de escritura única mediante PutRecordOperaciones de escritura por lotes mediante PutRecordBatch

La entrega de transmisiones de Amazon Data Firehose a Apache Iceberg Tables en Amazon S3 está en versión preliminar y está sujeta a cambios.

Las traducciones son generadas a través de traducción automática. En caso de conflicto entre la traducción y la version original de inglés, prevalecerá la version en inglés.

AWS SDK

Puede utilizar Amazon Data Firehose API para enviar datos a una transmisión de Firehose mediante Java,.AWS SDK NET, Node.js, Python o Ruby. Si es la primera vez que utiliza Amazon Data Firehose, tómese un tiempo para familiarizarse con los conceptos y la terminología que se presentan en. ¿Qué es Amazon Data Firehose? Para obtener más información, consulte Comience a crear con Amazon Web Services.

Estos ejemplos no representan códigos listos para producción, ya que no comprueban todas las excepciones posibles ni toman en cuenta todas las consideraciones de seguridad y desempeño posibles.

La Amazon Data Firehose API ofrece dos operaciones para enviar datos a su transmisión Firehose: y. PutRecordPutRecordBatch PutRecord()envía un registro de datos en una llamada y PutRecordBatch() puede enviar varios registros de datos en una sola llamada.

Operaciones de escritura única mediante PutRecord

Para colocar datos solo se necesita el nombre del flujo Firehose y un búfer de bytes (<=1000 KB). Dado que Amazon Data Firehose agrupa varios registros por lotes antes de cargar el archivo en Amazon S3, es posible que desee añadir un separador de registros. Para colocar los datos registro por registro en una transmisión de Firehose, usa el siguiente código:

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

Para obtener más información sobre el contexto del código, consulte el código de ejemplo incluido en. AWS SDK Para obtener información sobre la sintaxis de solicitud y respuesta, consulte el tema correspondiente en Firehose API Operations.

Operaciones de escritura por lotes mediante PutRecordBatch

Para colocar datos solo se necesita el nombre de la secuencia Firehose y una lista de registros. Dado que Amazon Data Firehose agrupa varios registros por lotes antes de cargar el archivo en Amazon S3, es posible que desee añadir un separador de registros. Para colocar los registros de datos en lotes en una transmisión de Firehose, utilice el siguiente código:

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

Para obtener más información sobre el contexto del código, consulte el código de ejemplo incluido en. AWS SDK Para obtener información sobre la sintaxis de solicitud y respuesta, consulte el tema correspondiente en Firehose API Operations.