amazon-kinesis 相关问题

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

如何在AWS Quicksight中显示_real_ realtime? [关闭]

我有一些带有MQTT的IoT设备,我正在使用AWS IoT Analytics向AWS Quicksight添加一些数据集。这很好用,但afaik不是实时的。所以我尝试了AWS Kinesis,构建了一些流+ S3但......

回答 1 投票 0

AWS Lambda无法连接到RDS实例,但我可以在本地吗?

我正在尝试从lambda连接到我的RDS实例。我在本地写了lambda并在本地测试,一切都很好用。我部署到lambda,突然它不起作用。以下是......

回答 2 投票 10

如何将视频数据发送到Kinesis视频流?

我已经阅读了Kinesis Video Stream文档(Javascript)几天了,现在我无法弄清楚如何发送我的视频?我还阅读了Kinesis文档和firehose,但没有运气。一世 ...

回答 1 投票 0

如何实现Amazon Connect - > AWS Kinesis视频流 - > Lambda - >在S3中保存可听的.wav(直播)

尝试将Amazon Connect配置为与AWS Kinesis Video Streams的实时流对话,然后触发使用GetMedia API对此录制进行采样并将其发送到的Lambda函数(Python)...

回答 1 投票 0

Kinesis消费滞后监测

我正在尝试在流级别收集Kinesis的指标,更具体地说,想要获得工作者/消费者进程在流级别上落后的计数,我不关心...

回答 1 投票 2

验证错误...成员必须满足正则表达式模式:arn:aws:iam ::

我正在尝试通过kinesis数据流来传输rds,但它给了我这个错误:botocore.exceptions.ClientError:调用PutRecord操作时发生错误(ValidationException):...

回答 1 投票 0

如何将记录从NodeJS应用程序(lambda)放入Kinesis流

我有一个lambda函数,需要将记录放入Kinesis流。我没有收到错误(我承认),但消息似乎永远不会出现在流...我知道流...

回答 1 投票 1

Kinesis使用java交叉帐户访问

我想写一个Java进程,它将使用STS来承担帐户中的角色A从Kinesis读取,然后将事件发送到帐户B中的Kinesis流。我怎样才能实现这一点,因为目前它是......

回答 1 投票 0

如何将AWS Kinesis流用于多个不同的数据源

我们有一个传统的批处理应用程序,我们从多个来源(Oracle,Salesforce,FTP文件,Web日志等)中提取数据。我们将传入的数据存储在S3存储桶中并在EMR上运行Spark以...

回答 1 投票 0

Spring Integration Kinesis适配器和消费者组

我有一个使用spring-integration-aws版本1.1.0.RELEASE开发的kinesis消费者应用程序。在我的测试中,我在同一个使用者组中运行此应用程序的两个实例并且......

回答 1 投票 0

Spring集成Kinesis - 找不到合适的实现

我正在运行这个示例 - Spring Cloud Stream Kinesis Sample by Spring云。我在Windows 7中的用户文件夹下的.aws文件夹中的凭据。启动应用程序时,我得到以下内容...

回答 1 投票 0

如何暂停/恢复aws lambda函数

例如,我有lambda函数消耗来自KinesisStream的消息。如何停止和恢复功能,以便我不会产生费用,我不会在流中丢失数据。我知道如果......

回答 2 投票 9

AWS SQS FIFO或AWS DynamoDB用于处理大量消息

我们有一个业务场景来处理大量的消息。关键因素是消息的顺序很重要。如果我们考虑使用AWS SQS FIFO,它每秒只能处理300条消息。这是 ...

回答 1 投票 0

如何从窗口中仅获取最新的行

我正在使用Kinesis Analytics,我正在尝试了解如何编写我的应用程序,以便在24小时内为我提供一个滑动窗口。我有什么生成正确的数据,但它看起来像......

回答 1 投票 0

Node.js中的代码AWS Lambda Package不会调用putRecord()来将数据添加到AWS Kinesis Firehose Stream中

我已经构建了一个AWS Lambda部署包(使用Node.js),当对象进入指定的S3存储桶时执行该包。我已经将执行的代码配置为,现在,随机添加10 ...

回答 1 投票 0

如何处理AMAZON Kinesis中的静态数据?

我们如何在Amazon kinesis中处理静态数据?例如,我在excel表中有数据,我想在Kinesis中处理它们。可能吗?如果是,那么如何实现呢?

回答 1 投票 0

AWS Firehose中间S3存储桶和传输流依赖关系出现问题

为多个传输流设置一个s3存储桶是个好主意吗? (例如:考虑两个具有不同流吞吐量的传输流,s3缓冲区大小/缓冲区间...)如果两个传递...

回答 2 投票 0

kinesis代理到lambda,如何获取原始文件和服务器

我有一个kinesis代理,它将很多日志文件信息传递给kinesis流,我有一个Lambda函数来解析信息。在Lambda上除了字符串我需要知道源...

回答 1 投票 0

Kinesis Firehose演示没有分隔符; Redshift无法解析。哪个错了?

当我今天完成Kinesis,Firehose和Redshift的第一步学习步骤时,我很高兴地发现亚马逊有一个“尝试我们的演示数据生成器”设置。我很沮丧地得知它......

回答 1 投票 0

IAM角色ARN Rekognition创建流处理器

我正在尝试使用来自流媒体Kinesis的AWS脸部识别,但却陷入了创建流处理器步骤的错误:错误的AccessDeniedException:状态代码:400,请求ID:d871329b-4553 -...

回答 1 投票 0

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