AWS Lambda Function intended to be used by authorized callers to view a Kinesis Video Stream's HLS session URL.

aws-lambda-kvm-gethlsstreamingurl.js

const AWS = require('aws-sdk')

AWS.config.region = process.env.AWS_REGION

const kinesisvideo = new AWS.KinesisVideo({
  accessKeyId: process.env.ACCESS_KEY_ID,
  secretAccessKey: process.env.SECRET_ACCESS_KEY
})

function getStreamingSessionURL(){
  return new Promise((resolve, reject) => {
    var getEndpointParams = {
      APIName: 'GET_HLS_STREAMING_SESSION_URL',
      StreamName: process.env.STREAM_NAME
    }

    kinesisvideo.getDataEndpoint(getEndpointParams, (err, data) => {
      if(err){
        console.log(err, err.stack)
        reject(`Failed to get KVS data endpoint: ${err.errorMessage}`)
      }else{
        console.log(`Get data endpoint response: ${JSON.stringify(data)}`)

        const kinesisvideoarchivedmedia = new AWS.KinesisVideoArchivedMedia({
            accessKeyId: process.env.ACCESS_KEY_ID,
            secretAccessKey: process.env.SECRET_ACCESS_KEY,
            endpoint: data.DataEndpoint
        })

        const getStreamingSessionURLParams = {
          Expires: 300,
          PlaybackMode: 'LIVE',
          StreamName: process.env.STREAM_NAME
        }

        kinesisvideoarchivedmedia.getHLSStreamingSessionURL(getStreamingSessionURLParams, function(err, data) {
          if (err){
            console.log(err, err.stack)
            reject(`Failed to get KVAM HLS streaming session url: ${err.errorMessage}`)
          }else{
            console.log(`get hls streaming session url response: ${JSON.stringify(data)}`)
            resolve(data)
          }
        })
      }
    })
  })
}

exports.handler = async (event, context, callback) => {
  await getStreamingSessionURL()
    .then((result) => callback(null, result))
    .catch((err) => callback(err))
}