使用KIT将Kinesis Video Streams与Amazon SageMaker集成

如何解决使用KIT将Kinesis Video Streams与Amazon SageMaker集成

我正在一个项目中，我需要将IP摄像机中的视频发送到Kinesis Video Stream，并使用Sagemaker托管我的ML模型，然后该模型将实时分析Kinesis Video Stream中的视频。
我点击了以下链接：https://aws.amazon.com/blogs/machine-learning/analyze-live-video-at-scale-in-real-time-using-amazon-kinesis-video-streams-and-amazon-sagemaker/
我已经完成了这些事情-

设置IP摄像机和运动视频流以将视频从IP摄像机发送到KVS
设置KIT的云形成模板（如链接中所述）

我对这件事特别感兴趣-

我如何从sagemaker笔记本中的aws fargate获得视频帧作为输入（如下图，第3步所示）？在链接中提到，该KIT预先捆绑了一个自定义Lambda函数，该函数编写为使用 Object Detection algorithm 处理Amazon SageMaker示例之一的预测输出。我不确定该算法如何从KVS获取输入。

请有人帮助我。

解决方法

嗨，我是韩国的云架构师

首先请记住，Lambda没有连接到Kinesis Video Stream。然后示例如何获取Kinesis Video Stream的帧数据。这是CloudFormation中的AWS ECS Docker映像。

DockerImageRepository:
    Type: String
    Default: >-
      528560246458.dkr.ecr.us-east-1.amazonaws.com/kinesisvideosagemakerintegration_release:V1.0.3
    Description: Docker image for Kinesis Video Stream & SageMaker Integration Driver.

创建CloudFormation是XML文件代码。在此文件中，您可以确认创建Docker Image。因此，您应该在Docker Image中检查代码。

我无法在Docker Image中打开代码。但是我可以在Github中找到Java代码。

https://github.com/aws/amazon-kinesis-video-streams-parser-library

https://github.com/aws/amazon-kinesis-video-streams-parser-library/tree/master/src/main/java/com/amazonaws/kinesisvideo/parser/utilities

https://github.com/aws/amazon-kinesis-video-streams-parser-library/blob/master/src/main/java/com/amazonaws/kinesisvideo/parser/utilities/FrameRendererVisitor.java

https://github.com/aws/amazon-kinesis-video-streams-parser-library/blob/master/src/main/java/com/amazonaws/kinesisvideo/parser/utilities/OutputSegmentMerger.java

此代码可能在Docker Image中运行。首先，此代码在Kinesis Video Stream上读取了i-Frame。其次，与之前的i-Frame进行比较。第三发送到SageMaker端点并获得Sagemaker推断。最后发送给Kinesis（而非Kinesis Video Stream），然后Lambda接收Sagemaker推论。

我在开发产品中尝试了这个示例。您应该跟随我的Github进行交流

https://github.com/WooSung-Jung