Amazon Kinesis是一种全面管理的服务，用于大规模实时处理流数据。
我有一个在Apache Beam（使用Spark Runner）中开发的流传输管道，它从运动学流中读取。我正在寻找Apache Beam中用于管理运动学检查点的选项（即商店...
我有一个分片大小为5的Kinesis数据流，它会触发批处理大小为1的lambda。从日志中看，即使有...，lambda函数也会与一条记录异步触发，即使有....
我何时需要将Kinesis Data Streams与Kinesis Firehose一起使用？
我想建立一个我想进行实时分析的用例。我不确定何时需要在Kinesis Firehose之前使用Kinesis Data Streams。在文档中说Kinesis ...
我的json对象是：{“ values”：{“ empid”：20000，“ empName”：“ Sourav”，“ empSal”：8200}}但我想删除“ Values：”。我怎样才能做到这一点。我已经用Python编写了代码。在后台正在采取...
这有点浅层次的问题。但是，我对这三项服务感到困惑。我了解KPL会生成快速数据，而KCL会使用Kinesis生成的快速数据。但是，我...
在使用带WebRTC的AWS Kinesis Video流进行视频通话时，保存视频
我正在使用aws kinesis视频流webRTC在reactjs中进行视频聊天。一切都很好。但是我想将视频存储在s3存储桶中。我应该如何实现此视频存储？
对于不到10％的客户端，对AWS.kinesisVideo api的调用失败。它被CORS政策阻止。事实是，对于绝大多数客户而言，这并不是真的。它与...
我有一个用例，其中有一个现有的Kinesis流，但我不知道有多少个分片。但是我必须创建一个消费应用程序，该应用程序将从...
我正在尝试将媒体流放入Kinesis Video Stream。由于Javascript SDK尚不支持此功能，因此我想知道是否有任何解决方案可以在没有Java的情况下使其正常工作...
我是新来的aws。我无法获得将流数据从MYSQL写入或迁移到AWS Kinesis的逻辑。任何帮助，将不胜感激。提前谢谢。
运动学事件源映射中的ParallelizationFactor
我正在通过事件源映射将Kinesis流连接到Lambda函数，如文档中所建议的那样，希望将并行化因子值设置为1到10之间的任何值：https：// ...
我想使用运动视频流webrtc javascript sdk从网页生成视频流。 sdk自述文件说我需要提供accessKeyId和secrectAccessKeysignalingClient = new ...
改变运动的aws lambda消费者批处理大小会导致数据丢失或重复吗
我有一个现有的运动学流和具有不同批次大小的多个lambda使用者。我想将lambda的批处理大小之一（从25更新为1000）。由于编辑选项不可用，因此我...
Spring集成，运动学粘合剂，localstack异常行为
使用测试容器的弹簧集成，运动学结合器和局部堆栈（aws局部环境），我遇到了一个非常奇怪的问题。我有2个频道-A和B。在每个频道上我都有生产者和消费者...
将AWS Firehose交付到VPC中的交叉帐户Elasticsearch
我在帐户A中运行的VPC中有一个Elasticsearch。我想将日志从帐户B中的Firehose传递到帐户A中的Elasticsearch。可以吗？当我尝试创建传递流时...
Amazon Kinesis在用Maven编译的Flink作业中找不到主类
[尝试在Amazon Kinesis Data Analytics中执行用Maven编译的Flink作业，并且出现以下错误：“ org.apache.flink.client.program.ProgramInvocationException：都没有'Main-Class'，...] >
如何从botocore.response.StreamingBody解析视频的第一帧？
我正在从Kinesis Video Stream get_media中接收以字节为单位的MKV视频的botocore.response.StreamingBody：client = boto3.client（'kinesis-video-media'，endpoint_url =' '，... ] >>
我正在尝试确定是否有一种方法可以优先考虑优先从流中首先获取的数据，而不管它何时放入流中。例如，我正在将两种类型的数据A和B写入...