Kinesis视频流异步获取帧

Question

import asyncio

import aiobotocore

VIDEO_STREAM_NAME = 'bc-test1'


async def get_data2(loop):
    chunk_size = 1024 * 1024 * 500
    session = aiobotocore.get_session(loop=loop)
    async with session.create_client('kinesisvideo', region_name='us-west-2', ) as client:
        resp = await client.get_data_endpoint(
            StreamName=VIDEO_STREAM_NAME,
            APIName='GET_MEDIA',
        )
        data_url = resp['DataEndpoint']

    async with session.create_client('kinesis-video-media', endpoint_url=data_url) as client:
        resp = await client.get_media(
            StreamName=VIDEO_STREAM_NAME,
            StartSelector={"StartSelectorType": "NOW", },
        )
        print(resp)
        while True:
            data = await resp['Payload'].read(1024 * 8)
            if data:
                print("frame len: %s" % len(frame))
            else:
                print("No data")
                break


def main():
    loop = asyncio.get_event_loop()
    loop.run_until_complete(get_data2(loop))


if __name__ == '__main__':
    main()

我会考虑不要将Asyncio与其他解决方案一起使用以满足上述需求的建议。

Answer 1

一定要是Python吗？

KinesisVideoStream在Java中有使用流、解析数据和解码视频的示例：https://github.com/aws/amazon-kinesis-video-streams-parser-library

KinesisVideoStream也有工具包：https://aws.amazon.com/blogs/machine-learning/analyse-live-video-at-scale-in-real-time-using-amazon-kinesis-video-streams-and-amazon-sagemaker/它可以用来处理规模上的视频流。