我正在使用Java API for Kinesis Firehose，并在可能的情况下使用putRecordBatch()。putRecordBatch返回一个整数，表示发送的一组记录提交失败的次数，例如，2次失败，4次失败，而putRecord()要么成功，要么抛出异常。我更喜欢在任何地方都使用putRecordBatch()，但是文档说只有在有多个记录要提交时才使用它。
这可能有点冒险，但是在座的任何人都有使用这个API，特别是这些方法的经验吗？您是否做了我正在考虑的事情，并且在所有
浏览 0提问于2016-12-23得票数 4
我正在寻找一个使用putrecordbatch发送多个记录到kinesis streams的示例。
我目前正在使用putrecord命令，通过以下方式将记录发送到kinesis streams。aws firehose put-record --delivery-stream-name csvtoredshiftstreamingjson --record='Data="{\"productid\":1，\"productname\":\&quo
浏览 17提问于2017-03-02得票数 1
回答已采纳
我之所以问这个问题，是因为我没有看到任何正式文档提到从AWS函数到FireHose执行FireHose。我想在PutRecord FireHose上执行AWS的操作。我还为我试图使用的AWS函数提供了适当的PutRecord策略。当使用AWS使用PutRecord 2.2执行PutRecord操作时，我得到以下错误
用户: arn:aws:sts::accountnumber:assumed-role/listener-role/lambda未被授权
浏览 1提问于2020-02-06得票数 0
我的代码托管在一个EC2实例上，它设法发送tweet，但在Kinesis上什么也没有显示(我认为上面的错误是罪魁祸首)。
浏览 34提问于2021-05-09得票数 0
我已经安装了一个Amazon，其中安装了Kinesis，并将其配置为将日志发送到Firehose。EC2实例被附加了一个带有KinesisFirehoseFullAccess权限的IAM角色。: arn:aws:sts::1245678012:assumed-role/FirstTech-EC2-KinesisFireHose/i-0bdf3adc7a4d97afa是未授权执行的：消防喉:PutRecordBatchon资源: arn:aws:firehose:ap-southeast-1:124567
浏览 5提问于2020-03-31得票数 1
这是我的密码AWS.config.update({ region: 'us-east-1' });exports.handler = async (event,context,callback) => { const, Value:even
浏览 1提问于2018-11-04得票数 1
回答已采纳
我正在测试一个cloudwatch警报过滤器(准确地说，检查lambda在内存中是否已满)，以发送到SNS，然后再发送到SQS队列。但是，我没有在日志中看到筛选器。设置为cloudwatch (filtered alarm) -> SNS -> SQS ->splunkresource "aws_cloudwatch_metric_alarm" "general_lambda_error" { "aws_cloudwatch_log_metric_filter
浏览 5提问于2019-03-27得票数 3
" { effect = "Allow" "firehose:PutRecord", name = "SesfirehosedestinationPolicy"
p
浏览 18提问于2022-01-20得票数 0
1回答
从下面这个问题开始，我创建了一个DynamoDB表(购买销售)，并添加了DynamoDB流。然后，我配置了Lambda函数以拾取DynamoDB流。我的问题是如何配置Kinesis来获取Lambda函数源？我知道如何配置Lambda转换，但是我想作为源代码来选择。不确定如何配置下面的Direct源代码。
浏览 1提问于2018-06-11得票数 0
回答已采纳
我有一个触发器，它为在Kinesis上接收到的每个事务执行lambda函数。生产者通过PutRecordsRequest()方法发送多个事务。Lambda函数如下；var firehose = new AWS.Firehose(); if
浏览 8提问于2017-03-24得票数 3
回答已采纳
2回答
我正在使用Lambda通过Firehose向Redshift发送批量消息。根据，如果有一些传递问题(有毒的消息，端点关闭等)，Firehose将继续尝试24小时并删除该消息。
浏览 0提问于2016-02-16得票数 3
uri = "arn:aws:apigateway:{region}:firehose:PutRecord/{service_api}"
我不知道service_api应该是什么。
浏览 5提问于2017-10-21得票数 6
回答已采纳
1回答
我正在编写一个函数来使用Node写到AWS Kinesis消防软管。写入消防水管流的AWS函数调用根据操作结果返回“错误”或“数据”。“ var readingObjects = getReadings(records); DeliveryStreamName: process.env.KINESIS_FIREHOSE_STREAM_DELIVERY,R
浏览 0提问于2019-10-22得票数 1
回答已采纳
我可以做相当多的事情，但我完全被困在如何设置Firehose并允许lambda写入它。resources: FirehoseBucket: Properties:
BucketName: my-firehose-bucket
浏览 0提问于2016-08-29得票数 3
下面是Lambda代码： const AWS = require('aws-sdk'); Record: { }console.log('params', params);
firehose.<em
浏览 7提问于2020-11-05得票数 1
回答已采纳
我正在使用Kinesis消防水带传输流。我使用PutRecord应用程序接口将记录放入交付流中。一个观察值putRecord将记录作为参数，并在内部接受byteBuffer。现在，我在nodejs中实现了lambda函数，以便对kinesis firehose流中的记录进行转换。
在我的lambda函数中，我得到的是字节流，而不是在lambda函数中的字符串。
浏览 2提问于2018-05-19得票数 0
我曾经能够将一张记录发送到firehose而不会出现这样的问题我曾尝试将{“foor”：“based64”}转换为InvalidArgumentException，但后来我得到了bar
aws firehoseData=e1wiYXNkZlwiOlwidGVzdGF
浏览 0提问于2020-07-09得票数 4
我有一个AWS Kinesis Firehose Stream设置为将数据馈送到AWS ElasticSearch集群，我可以通过将文档发送到Firehose Stream来成功插入文档，Firehose但我希望能够在将文档发送到Firehose Stream时手动指定/设置文档的id值。我成功地使用了AWS PHP SDK将数据发送到Firehose，但我不知道是否有办法手动设置文档的id。}', // REQUIRED];
$f
浏览 0提问于2016-05-11得票数 17
创建CloudWatch订阅筛选器并从Firehose目标进行订阅。使用Lambda转换函数提取数据，将其放回流中，并让Firehose将数据发布到ElasticSearch/S3。相反，我确实理解Firehose确实提供批处理，我可以在一定程度上控制它。
有人能在这方面给点建议吗？有没有其他我可能忽略的选择？感谢您的任何意见。
浏览 2提问于2018-07-07得票数 0
云服务器
对象存储
ICP备案
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号