lundi 16 décembre 2019

Validate data arrival time in aws lambda

I'm new in programming... Hope you will help me... My requirement is to write a Java condition if arrival time of data is less than 3 mins then send it to s3 or else dont send...

My code sample is below

public class KinesisFirehoseTransformer implements RequestHandler {

@Override
public KinesisFirehoseResponse handleRequest(KinesisFirehoseEvent event, Context context) {
    context.getLogger().log("Input: " + event);

    List<KinesisFirehoseOutputRecord> results = event.getRecords().stream().map(record -> {
            KinesisFirehoseOutputRecord outRec = new KinesisFirehoseOutputRecord();
            outRec.setRecordId(record.getRecordId());
            outRec.setData(record.getData()); 
            outRec.result = KinesisFirehoseResponse.TRANSFORMED_STATE_DROPPED ;
            return outRec;
        }).collect(Collectors.toList());

    return new KinesisFirehoseResponse(results);
}

}

Aucun commentaire:

Enregistrer un commentaire