async function putRecords()

in functions/source/LoggingProcessorLambda/index.js [81:94]

• 11 lines of code
• 2 McCabe index (conditional complexity)

async function putRecords(records, deliveryStreamName) {

    const firehose = new aws_sdk.Firehose();

    const recordChunks = chunkArrayInGroups(records, 500);

    for (const chunk of recordChunks) {
      const params = {
        DeliveryStreamName: deliveryStreamName,
        Records: chunk
      }
      await firehose.putRecordBatch(params).promise();
    };
}