Amazon Kinesis是一种全面管理的服务,用于大规模实时处理流数据。
我正在评估运动学以替代kafka。我缺少的一件事是Schema注册表等效解决方案。我特别需要:架构升级-验证与先前版本的兼容性...
假设我有2个Lambda,即LambdaA和LambdaB。两个lambda都是独立的lambda,它们具有不同的功能。我也有一个叫做KinesisA的Kinesis,它是一个没有...
Disclamer:我从没用过Kinesis。上下文:我们正在设计一种服务,该服务每分钟从4.1M Items DynamoDB表中获取数据,我们基于一个Items属性进行分组,然后编写...
我正在尝试使用Amazon的Video Signaling服务来创建多用户视频聊天系统。似乎唯一受支持的拓扑是“一对多”。 KVS是否支持多对多?即一个...
我正在使用AWS CLI获取一些Kinesis指标-其中一部分,我可以将输出格式指定为以下之一:https://docs.aws.amazon.com/cli/latest/userguide /cli-chap-configure.html#...
我如何从AWS Kinesis Data Stream事件访问数据?
我正在研究使用AWS Kinesis数据流的Python lambda。但是我在努力理解运动学记录事件的形式。例如:{“ Records”:[{“ ...
AmazonDynamoDBException:用户:无权执行用户名:dynamodb:资源上的DescribeTable
我正在尝试使用带有弹簧云蒸汽粘合剂运动的弹簧靴连接到Amazon firehose,以从fireshose流中读取数据。我正在关注以下异常,并且不确定为什么要尝试...
Forward Kinesis数据->(不同的AWS账户)Kinesis?
是否有一种简单的方法将数据从一个帐户的运动流转发到另一帐户的运动?数据->(AWS帐户A)Kinesis --->(AWS帐户B)Kinesis->消费者...
我建立了一个新的Kinesis数据流,并向其中写入了一些数据。然后我意识到我还没有设置Kinesis Firehose,所以我也进行了设置。我希望Firehose收集已写入的数据...
如何将视频从运动学视频流传输到AWS Rekognition并对该视频执行数据分析?
我正在将视频从Raspberry Pi传输到Amazon Kinesis视频流(此部分已完成)。现在,我想将视频发送到AWS Rekognition并在实时视频上执行面部检测。请在...
Kinesis Video Streams C ++ Producer SDK中的GStreamer
我在./install-script之后所做的一切,但是当我运行./gstreamer-plugin-install-script时,这向我显示下面的错误指南,我按照https://diycode.cc/projects/awslabs/amazon-kinesis进行操作-video-streams -...
[当我尝试在Terraform中创建Kinesis Firehose传递时,我不断收到此错误:错误:创建Kinesis Firehose传递流时出错:InvalidArgumentException:Firehose无法承担...
Flink Kinesis Connector不以最大容量使用Kinesis Data Streams的消息
我正在测试Apache Flink(使用v1.8.2)从Kinesis Data Stream读取消息的速度。 Kinesis Data Streams仅包含一个分片,并且包含40,000条消息。每个消息的大小是...
我被要求编写代码以使用Amazon Kinesis Firehose将.csv文件发送到S3。但是作为一个从未使用过Kinesis的人,我不知道该怎么做。您可以帮忙吗,或者如果您...
Amazon Kinesis Firehouse to S3
我被要求编写代码以使用Amazon Kinesis Firehouse将.csv文件发送到S3。但是作为一个从未使用过Kinesis的人,我不知道该怎么做。您可以帮忙吗,或者如果您...
我找不到任何地方谈论减少数量的碎片会发生什么,即如果我通过控制台将2的碎片数量从2更改为1,那么消费者会自动链接到新的碎片或需要...]
我正在使用AWS Kinesis Video Streams将我的相机流式传输到云上。然后,我使用Sagemaker使用AWS Lambda对其进行分析,该工具会在视频中返回对象的名称及其坐标...
将大型csv文件从s3复制到redshift的最佳方法是什么?
我正在将sv文件从s3存储桶复制到redshift的任务。我已经找到了多种方法来做到这一点,但是我不确定哪种方法是最好的方法。这是场景:On ...
我将自愿提出几点:我是Flink的新手(大约工作了一个月),我正在使用Kinesis Analytics(AWS托管的Flink解决方案)。从所有方面来看,这实际上并没有限制...
NextShardIterator从运动学流中读取数据时永远不会返回null
我正在尝试在lambda函数中的特定时间戳记之后从运动学流中读取记录。我得到了碎片,碎片迭代器,然后是数据。当我得到第一个迭代器时,就得到了数据...