const command = new GetObjectCommand(getObjectParams); const data = await s3Client.send(command); const stream = data.Body; const [streamForRecordCount, streamForEntireRecords] = duplicateStream(stream); const recordedCount = await processRecordCount(streamForRecordCount); const records = await processEntireRecords(streamForEntireRecords); console.log(“records”, records); Above is code in Node.js where a stream of a CSV file is fetched from AWS S3. A stream is split into two since […]