kvs-get-streaming-session-url.js

const AWS = require('aws-sdk')

AWS.config.region = process.env.AWS_REGION

const kinesisvideo = new AWS.KinesisVideo({
})

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({
            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.code} ${err.message}`)
          }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))
}