在无服务器框架中配置lambda函数时，我尝试添加一个kinesis流作为事件过程：functions: handler: handler.fooevents: arn: arn:aws:kinesis:us-east-1:783995676505:stream/search-helperbatchSize: 100
startingPosition: LAT
浏览 2提问于2017-08-07得票数 1
2回答
交叉触发
、、
我试图在帐户'B‘中触发一个lambda，通过帐户'A’中的动态流来触发。这类似于描述的，除了示例使用S3而不是Kinesis。 aws lambda add-permission \--statement-id 'Id-123'\
--action "
浏览 0提问于2017-02-24得票数 7
1回答
API每10秒更新一次，因此我希望在新数据出现时立即使用和填充我的Kinesis管道。但是，我不确定为此使用了哪种工具。我做了一个小小的研究，我想我有两个选择：
给定用例的标准方法是什么？
浏览 1提问于2021-06-09得票数 1
我有一个AWS Lambda函数，它会在每个Kinesis记录进入Kinesis时触发。但是，我希望使用特定数量的消息来触发Lambda函数。例如，我想用5条消息而不是1条消息来触发Lambda函数。
浏览 2提问于2016-10-05得票数 1
我正在设计一个基于一系列基于事件的微服务的小型平台。我所针对的持久性存储是(托管的) Amazon PostgreSQL (Amazon RDS for PostgreSQL) --尽管我也可以使用Amazon Aurora。基本上，如果我能听到一些内置的流，捕捉
浏览 0提问于2023-01-31得票数 1
我有一个AWS Kinesis Firehose Stream设置为将数据馈送到AWS ElasticSearch集群，我可以通过将文档发送到Firehose Stream来成功插入文档，Firehose
浏览 0提问于2016-05-11得票数 17
我是AWS的新手，尤其是Lambda的复杂性。我目前的目标是获得一个监听Kinesis流的Lambda函数。我好奇的是，在Kinesis流触发Lambda函数的情况下，谁是调用者(用于Lambda的export.handler回调)？换句话说，当在Lambda中成功执行回调时，谁是接收成功消息的调用者？例如，空白Lambda函数的起始模板：
exports.handler = (e
浏览 18提问于2017-07-19得票数 2
1回答
从下面这个问题开始，我创建了一个DynamoDB表(购买销售)，并添加了DynamoDB流。然后，我配置了Lambda函数以拾取DynamoDB流。我的问题是如何配置K
浏览 1提问于2018-06-11得票数 0
回答已采纳
我有一个连接到AWS Kinesis Stream (由其触发)的AWS lambda。当我在Kinesis中激发事件时，我的lambda会被调用。下面是一些将事件推送到Kinesis中的示例代码(此部分有效)： region: 'us-east-1'
浏览 0提问于2017-02-14得票数 1
回答已采纳
2回答
我使用从SNS事件触发器触发的AWS函数从SQS队列中使用。当Lambda函数执行时，它从队列中提取10条消息，对它们进行处理，再提取10条，等等--直到被编码到Lambda函数中的某个时间限制(很明显，小于5分钟的最大值)。我的理解是，由SNS事件触发的Lambda函数是一对一的，对吗？换句话说，一个SNS事件不会触发多个Lambda函数(最大并发执行限制)。没
浏览 4提问于2018-01-28得票数 1
回答已采纳
2回答
我们是否可以创建一个Lambda函数，当我们将记录写入Dynamo DB表时可以执行该函数&该记录被写入Kinesis流?？我们基本上可以使用Lambda函数写入Kinesis流吗？？如果是，请分享that..Also示例代码，我想知道work.....Thank是如何实现的
浏览 0提问于2015-11-20得票数 7
我想使用由触发状态机的第一个lambda的流生成的数据来执行一个步骤函数此Kinesis流用作执行和写入S3存储桶的lambda1的触发器。这将触发(使用步骤函数)一个lambda2，它将从给定的存储桶中读取内容，并将其写入另一个存储桶
现在，我想使用Amazon Step函数实现一个状态机。我已经创建了非常简单的状态机。"
浏览 2提问于2017-08-20得票数 2
回答已采纳
我正在尝试使用rest端点将数据从Kinesis转换为流到我自己的系统。我可以使用lambda来做到这一点。我想知道使用亚马逊消防站会有帮助吗？
浏览 1提问于2020-05-06得票数 0
2回答
我只是试着测试我的DLQ的Lambda，我不明白为什么消息不能放在上面。我的代码只做了一件事throw new Exception("Test");。在那之后，我设置了Kinesis并开始在上面发送消息，但是在CloudWatch metrics上没有changed.On监控页面，我看到Errors, Availability中有几个错误，但DeadLetterErrors
浏览 0提问于2018-10-04得票数 1
1回答
正确的运动原理
、、、
在AWS中，当将Kinesis流指定为主体时，应该使用什么主体？具体来说，我想用AWS::Lambda::Permission编写一个CloudFormation资源: lambda将由一个CloudFormation流触发。kinesis-stream.amazonaws.com
我查看了，但它没有任何关于主体的信息。流的命名空间似
浏览 4提问于2017-05-04得票数 1
假设正在进行直播，将在Kinesis上收集数据并处理这些数据。 假设发生了10秒，它将触发第一个lambda函数，并假设lambda函数只需要5秒来处理该数据。因此，第一个λ函数将在15 second.but内处理，假设来自Kinesis的一些实时数据流发生在12秒，并且它将再次触发lambda函数。那么，第二个lambda函数将在第一个lambda</e
浏览 8提问于2020-06-17得票数 0
我有不同类型的数据流经我的kinesis流。每条记录都有不同的分区键。只有在流中添加了具有特定分区键的记录时，我才需要调用lambda函数。有没有办法指定只有在遇到分区键"a“时才触发lambda，而不是调用lambda然后检查分区键？
浏览 4提问于2016-06-20得票数 1
我正在尝试部署一个Lambda函数，它是由AWS MSK Kafka触发的。这是否意味着AWS MSK和Lambda必须在同一个帐户下？难道没有办法解决这个问题吗？将实现一个代码卡夫卡的消费者工作？是什么推荐的方式来触发它？也许是克伦的表情？
浏览 6提问于2022-02-01得票数 1
回答已采纳
我正在实现一个涉及SQS的解决方案，它触发一个Lambda函数，使用第三方API来执行一些操作。第三方API有每秒请求数的限制，所以我想将Lambda函数处理的SQS消息的数量限制为类似的速率。有没有办法限制SQS上每秒可见的消息数量或Lambda函数每秒调用的数量？编辑过的
在关于AWS Kinesis的评论中给出了一些见解之后:由于Kinesis has的行为会在达到任何阈值时触发lambda执
浏览 2提问于2020-06-06得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
