我的代码托管在一个EC2实例上，它设法发送tweet，但在Kinesis上什么也没有显示(我认为上面的错误是罪魁祸首)。我已经向我的EC2实例授予了IAM权限(AmazonKinesisFullAccess)，所以我认为这应该不是问题。我已经确保在任何地方都使用正确的钥匙。 任何帮助都将不胜感激。
浏览 34提问于2021-05-09得票数 0
2回答
我正在使用Lambda通过Firehose向Redshift发送批量消息。根据，如果有一些传递问题(有毒的消息，端点关闭等)，Firehose将继续尝试24小时并删除该消息。我希望在X次失败尝试后将失败的消息移动到另一个队列中(本质上类似于)。最好的方法是什么，最好不交叉检查目标Redshift数据库？
浏览 0提问于2016-02-16得票数 3
我曾经能够将一张记录发送到firehose而不会出现这样的问题但是由于我已经将我的cli更新到了版本2，所以我得到了这个错误：
Invalid base64: "{"foor":"b
浏览 0提问于2020-07-09得票数 4
我正在尝试通过动态传递流向多个S3桶来流Punchweb钩子JSON数据，但是它给了我这个错误。但是，当我流入Iterable数据时，Iterable S3桶成功地填充了从Iterable发送的可交付流中的数据。下面是错误:调用'data/landing/vendor/punchh/punchh_to_dd/ex_points_remind
浏览 4提问于2022-02-19得票数 0
回答已采纳
我从API中获取流数据，然后通过Kinesis将原始数据发送到S3桶。有时，数据大小超过了我可以通过消防水管发送的限制，因此我得到以下错误
botocore.exceptions.ClientError:调用PutRecord操作时发生了一个错误(ValidationException)：检测到1va镇静错误:record.data处的
浏览 3提问于2021-08-05得票数 1
回答已采纳
遵循这个并创建一个Kinesis。我遵循了指南，当我创建订阅筛选器(步骤12)时，当我试图发送到S3时会遇到这个错误：我可以确认流是活动<
浏览 3提问于2020-07-29得票数 0
我正在尝试流的AWS云监视日志到ES通过Kinesis。下面的地形代码给出了一个错误。任何建议..。错误是：
aws_cloudwatch_log_subscription_filter.test_kinesis_logfilter: InvalidP
浏览 5提问于2017-05-12得票数 13
1回答
我正在编写一个函数来使用Node写到AWS Kinesis消防软管。写入消防水管流的AWS函数调用根据操作结果返回“错误”或“数据”。如果出现错误，对于特定的错误代码，我需要使用exponentialBackoff重试相同的请求。我使用setTimeOut为每次重试触发相同的方法，每次重试都有不同的时间，但每次重试时，我的解析都
浏览 0提问于2019-10-22得票数 1
回答已采纳
我正试图在aws上使用带有python3.6的将数据添加到流中。当调用流上的put记录时，我会得到以下异常。在帐户123456下调用ResourceNotFoundException操作: PutRecord流MyStream时发生错误(未找到)。我正在执行下面的python代码来向Stream添加数据。= session.cl
浏览 2提问于2019-03-07得票数 1
我已经读过了(AWS)的动态流(实时数据处理)的文档。但是，我对如何实现Kinesis感到困惑。
但是我怎么知道数据正在成功地保存在流中呢？我怎样才能把打印日志放进去？我想在控制台中显示成功保
浏览 3提问于2017-03-23得票数 2
有没有办法将数据从Lambda函数推送到Kinesis流？我已经在互联网上搜索过了，但没有找到任何与之相关的例子。
谢谢。
浏览 0提问于2016-06-29得票数 17
如下所示：调用InvalidParameterException操作时出错( PutSubscriptionFilter )：无法将测试消息传递到指定的消防软管流。检查给定的火管流是否处于活动状态。iam日志输入-订阅-过滤器-日志-组名称"xxxx“-过滤器名称"xxx”-筛选-模式"{$.httpMethod = GET}“-目的地-arn "arn:aw
浏览 1提问于2018-12-18得票数 4
回答已采纳
我有一个AWS移动消防软管，发送数据到红移通过S3。我希望在使用发送的记录之间出现新行。目前，我的代码如下所示：Aws::Firehose::Client.new(){"id":1,&q
浏览 1提问于2021-11-20得票数 0
回答已采纳
我们在生产中有一个不断更新的DynamoDB表，我们希望将所有记录从dynamoDB加载到redshift。
我们尝试使用copy命令，但由于表中不断插入新记录，因此copy命令将永远运行。我们想知道将数据从实时dynamodb加载到redshift的最佳方法是什么。
浏览 0提问于2015-05-13得票数 5
我有一个Kinesis集群，它通过Lambda将数据推送到Amazon Redshift中。目前我的lambda代码看起来像这样： client = boto3.client('redshift-data') query = # prepare an INSERT(更多分片)或lambda (从单个分片进行并发处理)时，我得到的结果是： [ERROR] ActiveStatementsExceededExcept
浏览 89提问于2021-10-26得票数 2
回答已采纳
1回答
我想对我的应用推荐模型使用personalize。来获取我当前的应用分析数据。我已经连接了pinpoint，以便在this documentation中解释的kinesis firehose的帮助下获得数据。 但是当我把运动数据传输到pinpoint的时候。 ? 我的pinpoint向kinesis发送数据。但输出结果与我想要的不同。 Kinesis设置： ? 以及我
浏览 35提问于2021-10-01得票数 1
回答已采纳
每个Kinesis应用程序必须包括以下三个组件：
现在我在这里了解到，一旦我们配置了生产者，将记录添加到Kinesis流中。然后，KCL应用程序可以通过以下processRecords实现从Kinesis读取记录。然后，这个processRecords方法
浏览 3提问于2014-06-30得票数 1
回答已采纳
我正尝试在AWS提供的jupyter笔记本电脑中使用spark / python读取kinesis流。我从AWS文档中获取了代码，但当我尝试使用kinesis创建数据帧时，我得到了一个依赖错误。下面是我的代码：from datetime import datetimeimport base64
from pyspark.sql importfrom pys
浏览 10提问于2021-07-20得票数 0
由于我已经设置了一个流，并且我希望使用一个标准的POST请求来调用流上的PutRecord调用，所以我一直在经历AWS方面的一些问题。我的问题是:我遗漏了什么东西吗？Kinesis是否需要标题a、b和c，而我只生成其中的两个呢？或者这个内部错误是一个实际的失败。我迷路了，因为我的反应表明我无法在我的一端做任何事。然而，我做了一些
浏览 0提问于2018-06-14得票数 2
回答已采纳
云服务器
ICP备案
对象存储
实时音视频
云直播
腾讯云开发者
