amazon-kinesis 相关问题

Amazon Kinesis是一种全面管理的服务,用于大规模实时处理流数据。

运动流中记录的顺序如何保证?

我想保证运动流的顺序。该流包含通过 aws dynamodb 流生成的记录。根据aws参考文档,不能保证

回答 0 投票 0

AWS Kinesis:并发能力

我一直在努力寻找关于 AWS Kinesis 并发能力的准确信息。 到目前为止,我对 AWS Kinesis 的输入并发和输出并发的理解各不相同……

回答 1 投票 0

尝试跨 AWS 账户访问 Kinesis 流时出现拒绝访问错误

我正在尝试从另一个 AWS 账户上的 lambda 函数访问一个 AWS 账户上的 Kinesis 流。 lambda 函数尝试使用 Amazon.Kinesis 从 AWS 账户中提取数据。

回答 2 投票 0

如何将 S3 中的事件文件从 Kinesis 流拆分成小块?

我有一个收集器正在将事件写入我的 S3 存储桶,然后我需要使用 COPY 命令将这些数据加载到 AWS Redshift 中。这些事件来自 SendGrid 和大约 11 个主题,SendGrid 提供...

回答 1 投票 0

Amazon Kinesis Video GetMedia/PutMedia

我使用 python 3.6,我想使用 API 将视频流发布到 aws kinesis。 我使用 python aws 客户端创建流和 GetDataEndPoint 但是当我想用我的自定义请求发布我的数据时(PutM ...

回答 2 投票 0

在仪表板上查看实时数据库更改的可能平台

我正在做一个使用 Django 的网站,该网站使用 AWS RDS Postgresql 作为数据库。目前,我想把数据库放在仪表板上,我可以从仪表板上看到数据库的实时变化...

回答 0 投票 0

Amazon Kinesis Publisher [关闭]

我想为 Amazon Kinesis 创建一个 POC。 我在这篇文章的帮助下在 AWS 上创建了一个流和一些代码 http://seroter.wordpress.com/2014/01/09/data-stream-processing-with-amazon-kines...

回答 1 投票 0

为 Kinesis 传输流启用服务器端加密需要哪些配置?

对于我当前的用例,我正在使用 Kinesis 交付流/firehose 来流式传输 Firewall Manager 日志。所以目前的设置是 Kinesis 在账户 A(与防火墙管理器相同的账户)中,并且

回答 0 投票 0

Kinesis delivery Role开启服务端加密需要什么权限?还有一些关于 Kinesis 和 KMS 的额外问题

对于我当前的用例,我正在使用 Kinesis 交付流/firehose 来流式传输 Firewall Manager 日志。所以目前的设置是 Kinesis 在账户 A(与防火墙管理器相同的账户)中,并且

回答 0 投票 0

找不到适合 thenReturn 的方法

我是 java 和 mockito 的新手,试图模拟我的 //kinesisClient 是 KinesisAsyncClient 类型 PutRecordResponse 结果 = kinesisClient.putRecord(putRecordRequest).get(); 如下所示: KinesisAsyncCl ...

回答 0 投票 0

AWS Kinesis Firehose + Lambda:如何处理同时发生的多个记录创建/更新

作为 Kinesis Firehose 工作流的一部分,我有一个链接到我的 Kinesis 数据流的 Lambda 函数。 lambda 函数真正做的就是获取来自 DynamoDB 的序列化记录,并且

回答 1 投票 0

AWS Cloudwatch Logs 订阅过滤器以将日志发送到跨账户 Kinesis Stream

目前有一个设置,我们通过订阅过滤器将日志数据管道传输到运动流,以进一步分析应用程序的任何意外行为或调试任何错误。这是在...

回答 1 投票 0

Kafka-kinesis 连接器错误:无法启动任务 XXX-0 (org.apache.kafka.connect.runtime.Worker:652)

我正在关注 kinesis-kafka GitHub 站点上的教程 https://github.com/awslabs/kinesis-kafka-connector 到目前为止,我已经使用 maven 编译了 kinesis-kaka-connector.jar 类库,我是

回答 1 投票 0

为什么在这种情况下使用带有 groupID 的 SQS FIFO 而不是使用带有分区键的 Kinesis Streams?

我正准备参加 AWS Solutions architecture Associate level certificate 的考试,我遇到了一个非常棘手的问题: 我认为 Kinesis Streams 是一个很好的解决方案,我们从多个接收数据...

回答 1 投票 0

我们可以使用Amazon Kinesis Video Streams with WebRTC发送连接到android设备的硬件摄像头的流媒体吗?

硬件是raspberry pi,通过wifi网络连接到android移动设备。树莓有一个连接的摄像头。我可以从硬件摄像头中获取流,并将其显示在...

回答 1 投票 -1

亚马逊流动症碎片数计算公式怎么用?

我正试图学习aws kinesis streams,and as per aws kinesis streams documentation. 每一个shard的摄取量可达1MBsec或1000 recordssec,允许读取量可达2MBsec,每一个shard允许5个事务 ...

回答 1 投票 0

AWS-Kinesis-Agent在自定义AMI和内部部署中:请求中包含的安全令牌无效。

我希望有人能帮助我,因为我对kinesis firehose和firehose agent相当陌生。我已经为我的预置 debian 服务器和 ec2 debian 实例编译了 kinesis-agent(在测试 aws ...

回答 1 投票 0

错误 java.lang.NoSuchFieldError。NO_INTS

当运行spark流媒体应用程序从kinesis中获取数据时,出现以下错误。在线程 "Kinesis Receiver 0 "中出现异常 java.lang.NoSuchFieldError: NO_INTS at com.fasterxml......。

回答 1 投票 0

在Localstack上创建Kinesis流时,Kinesis端口超时。

我试图使用在 Docker 上运行的 Localstack 创建一个 Kinesis 流。我的 docker-compose.yml 是这样的: version: '3.2' services: localstack: image: localstacklocalstack:last ...

回答 1 投票 0

spring cloud stream支持json header?

我们所有的消费类应用都使用spring-cloud-stream,但我们的一个大型生产类应用(legacy...)因为spring boot版本是1.4,所以不能使用spring-cloud-stream。但是我们的一个大型生产者应用(legacy...)不能使用spring-cloud-stream,因为spring boot版本是1.4。我们尝试用...

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.