Envoyer des données avec AWS SDK

Vous pouvez utiliser Amazon Data Firehose API pour envoyer des données vers un flux Firehose à l'aide du AWS SDKpour Java,. NET, Node.js, Python ou Ruby. Si vous utilisez Amazon Data Firehose pour la première fois, prenez le temps de vous familiariser avec les concepts et la terminologie présentés dans. Qu'est-ce qu'Amazon Data Firehose ? Pour plus d'informations, consultez Start Developing with Amazon Web Services.

Ces exemples ne représentent pas du code prêt à la production, car ils ne recherchent pas toutes les exceptions possibles ou ne tiennent pas compte de toutes les considérations possibles en matière de sécurité ou de performances.

Amazon Data Firehose API propose deux opérations pour envoyer des données à votre flux Firehose : et. PutRecordPutRecordBatch PutRecord()envoie un enregistrement de données au cours d'un appel et PutRecordBatch() peut envoyer plusieurs enregistrements de données au cours d'un appel.

Opérations d'écriture uniques utilisant PutRecord

L'ajout de données nécessite uniquement le nom du flux Firehose et un tampon d'octets (<=1000 Ko). Dans la mesure où Amazon Data Firehose regroupe plusieurs enregistrements avant de charger le fichier dans Amazon S3, vous souhaiterez peut-être ajouter un séparateur d'enregistrements. Pour placer les données un enregistrement à la fois dans un flux Firehose, utilisez le code suivant :

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

Pour en savoir plus sur le contexte du code, consultez l'exemple de code inclus dans le AWS SDK. Pour plus d'informations sur la syntaxe des demandes et des réponses, consultez la rubrique correspondante dans Firehose Operations API.

Opérations d'écriture par lots à l'aide de PutRecordBatch

La saisie de données nécessite uniquement le nom du flux Firehose et une liste d'enregistrements. Dans la mesure où Amazon Data Firehose regroupe plusieurs enregistrements avant de charger le fichier dans Amazon S3, vous souhaiterez peut-être ajouter un séparateur d'enregistrements. Pour placer des enregistrements de données par lots dans un flux Firehose, utilisez le code suivant :

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

Pour en savoir plus sur le contexte du code, consultez l'exemple de code inclus dans le AWS SDK. Pour plus d'informations sur la syntaxe des demandes et des réponses, consultez la rubrique correspondante dans Firehose Operations API.