kinesisFunction.js

// the KinesisHandler abstraction takes in a function that processes one
// record at a time so to allow us to inject the correlation IDs that
// corresponds to each record
module.exports.handler = kinesisHandler(
  co.wrap(function* (record, context) {
    reqContext.set("source-type", "kinesis");

    let host = reqContext.get()["x-correlation-host"];
    if (host) {
      let uri  = `https://${host}/dev/api-c`;
      
      log.info("calling api-c", { uri });
    
      let reply = yield http({
        uri     : uri,
        method  : 'GET'
      });
    
      log.info(reply);
    } 
  })
);