我如何确定我的Kinesis事件触发了哪个特定的Lambda请求？
Kinesis是亚马逊AWS提供的一种流式数据处理服务，而Lambda是AWS提供的无服务器计算服务。当Kinesis事件触发Lambda请求时，可以通过以下方式确定具体的Lambda请求：
- 使用AWS CloudWatch日志：在Lambda函数中，可以将日志信息发送到CloudWatch日志组。通过查看CloudWatch日志组中的日志，可以确定哪个特定的Lambda请求被触发。
- 使用AWS X-Ray：X-Ray是AWS提供的分布式应用性能分析服务。在Lambda函数中集成X-Ray，可以追踪和分析请求的调用链。通过X-Ray的分析，可以确定哪个特定的Lambda请求被触发，并查看其调用链信息。
- 使用唯一标识符：在Kinesis事件中，可以为每个事件添加唯一标识符。在Lambda函数中，可以通过读取事件中的唯一标识符来确定哪个特定的Lambda请求被触发。
- 使用AWS CloudTrail：CloudTrail是AWS提供的日志服务，用于记录AWS账户中的API活动。通过查看CloudTrail日志，可以确定Kinesis事件触发了哪个特定的Lambda请求。
总结起来，可以通过使用AWS CloudWatch日志、AWS X-Ray、唯一标识符或AWS CloudTrail来确定Kinesis事件触发了哪个特定的Lambda请求。
腾讯云相关产品推荐：
- 日志服务CLS：https://cloud.tencent.com/product/cls
- 云函数SCF：https://cloud.tencent.com/product/scf
- 云监控CM：https://cloud.tencent.com/product/cm
- 云审计CAM：https://cloud.tencent.com/product/cam
相关·内容
1回答
动态数据流不是实时的吗？
、、、
获得了在动态流消息(serverless.yml)上触发的函数：
functions:
kinesis-handler:
handler: kinesis-handler.handle
events:
- stream:
type: kinesis
arn:
Fn::Join:
- ':'
- - arn
- aws
- kinesis
浏览 5提问于2019-09-25得票数 3
回答已采纳
我们使用Kinesis作为Lambda的缓冲区，然后将其插入到Redshift中。Lambda函数在S3中创建一个文件，并在Redshift中复制以插入数据。我们看到Kinesis的数据延迟非常高，我们担心这会导致超过24小时的数据被丢弃。我们目前有3个分片在运行，并且还没有达到我们的最大吞吐量。
在同一时间内，我们也看到进入Kinesis的数据量在增加。然而，由于我们只使用了大约三分之一的写吞吐量，我们不应该被限制。在任何Lambda或Redshift指标中都没有波动。
附件中的文件显示了Kinesis流中的统计数据。是什么导致了这种情况的发生，我该如何着手修复它？
浏览 3提问于2015-08-04得票数 3
我正在调查AWS SAM是否可以在我正在工作的应用程序的上下文中使用。
基本上，应用程序的结构是这样的：
[kinesis event] -> [my lambda] -> [invokes another lambda]
或
[kinesis event] -> [my lambda] -> [creates a different kinesis event]
或
[another lambda] => [invokes my lambda] => [invokes yet another lambda]
因此，我希望能够编写一些测试，例如：
Given
浏览 0提问于2020-07-23得票数 3
我有一个连接到AWS Kinesis Stream (由其触发)的AWS lambda。当我在Kinesis中激发事件时，我的lambda会被调用。下面是一些将事件推送到Kinesis中的示例代码(此部分有效)：
var kinesis = new AWS.Kinesis({
region: 'us-east-1'
});
var params = {
Data: new Buffer(JSON.stringify(data)),
StreamName: 'myStreamName',
PartitionKey: uuid.v1()
};
k
浏览 0提问于2017-02-14得票数 1
回答已采纳
我将ES集群部署到access，它可以通过应用程序负载均衡器进行访问。我已经在集群中创建了一个索引。我将部署一个Kinesis来使用http_endpoint作为将数据流到ES集群的目标。
但是，我如何配置http谓词消防喉用于将数据放入ES端点呢？例如，我的ES端点是http://xxxx.com/myindex，我希望消防软管向这个端点发送POST请求。如何将其配置为使用POST而不是PUT
浏览 2提问于2021-06-15得票数 3
我已经创建了kinesis firehose传递流，它将响应文件存储到s3存储桶中，但是当使用kinesis存储文件或将文件放入存储桶中时，我无法在s3存储桶上触发事件。
浏览 1提问于2020-01-22得票数 1
我希望能够发送数据到kinesis firehose根据数据里面的内容。例如，如果我发送以下JSON数据：
{
"name": "John",
"id": 345
}
我想根据id过滤数据，并将其发送到我的s3存储桶的子文件夹中，如: S3://myS3Bucket/345_2018_03_05。使用Kinesis Firehose或AWS Lambda可以做到这一点吗？
我现在能想到的唯一方法是为我的每个可能的in创建一个kinesis流，并将它们指向相同的存储桶，然后将我的事件发送到我的应用程序中的这些流，但我希望避免这种情况，因
浏览 2提问于2018-05-15得票数 9
1回答
我是AWS的新手，所以我不知道发生以下情况时的行为是什么。
假设我有一个带有JSON数据的Kinesis流(假设每隔几分钟就会插入几千条消息)。
现在有一个Lambda函数，每次将一个新的msg插入到Kinesis中时都会调用它，它读取msg，并在插入Redshift之前进行一些处理。
那么，如果出现一些错误，而Lambda函数在处理过程中崩溃，并且需要几分钟甚至几个小时(我不知道这是否可能)，那么会发生什么呢？它将继续从最后一个未读消息中读取Kinesis，还是从最新插入的消息中读取(因为这是调用事件)。
提前谢谢。
浏览 0提问于2018-12-12得票数 2
我试图在一个lambda函数中读取特定时间戳之后的kinesis流的记录。
当我获得第一个迭代器时，我会获得数据，并继续使用NextShardIterator (出现在返回的数据中)递归地调用相同的函数。根据文档，当没有更多的数据可读并且已经到达$latest时，NextShardIterator将返回null。
但它从不返回null，并且函数不断被调用，最终我得到了预置的Throughput Exception异常。
我还尝试使用MillisBehindLatest在值为零时停止读取，但在某些情况下也会失败。
有没有一种根据时间戳从kinesis获取数据的正确方法？
浏览 0提问于2020-03-05得票数 1
我正试图通过terraform创建一个由Kinesis触发的lambda，她的失败目的地将是AWS SQS。
我创建了lambda并配置了源和目标。
当我向Kinesis发送消息时，将触发lambda，但不会向DLQ发送消息。
我遗漏了什么？
我的labmda源映射：
resource "aws_lambda_event_source_mapping" "csp_management_service_integration_stream_mapping" {
event_source_arn = local.kin
浏览 8提问于2022-03-02得票数 2
回答已采纳
1回答
我正在接收Kinesis数据流中的cloudtrail日志。我正在调用一个流处理lambda函数，就像here描述的那样。然后将返回到流的最终结果存储到S3存储桶中。到目前为止，处理失败，并在S3存储桶中创建了以下错误文件： {"attemptsMade":4,"arrivalTimestamp":1619677225356,"errorCode":"Lambda.FunctionError","errorMessage":"Check your function and make sure the ou
浏览 15提问于2021-04-29得票数 0
1回答
正确的运动原理
、、、
在AWS中，当将Kinesis流指定为主体时，应该使用什么主体？具体来说，我想用AWS::Lambda::Permission编写一个CloudFormation资源: lambda将由一个CloudFormation流触发。主体必须来自
这些都不适合我：
kinesis.amazonaws.com
kinesisstream.amazonaws.com
kinesisstreams.amazonaws.com
kinesis-stream.amazonaws.com
我还没有找到任何将服务映射到主体的文档。我找到了，它显示了kinesisanalytics.amazo
浏览 4提问于2017-05-04得票数 1
1回答
我是aws python boto3中的一个lambda。我将此lambda (触发器)配置为从特定的运动流读取。它必须从事件对象中读取流名。我不知道怎么知道流的名字。我不想在代码中硬编码Kinesis流的名称。我想从事件中读出来。
import boto3
import json
from pprint import pprint
s3 = boto3.client('s3')
kinesis = boto3.client('kinesis')
def lambda_handler(event, context):
浏览 3提问于2022-09-15得票数 0
回答已采纳
1回答
我想对我的应用推荐模型使用personalize。来获取我当前的应用分析数据。我已经连接了pinpoint，以便在this documentation中解释的kinesis firehose的帮助下获得数据。 但是当我把运动数据传输到pinpoint的时候。 ? 我的pinpoint向kinesis发送数据。但输出结果与我想要的不同。 Kinesis设置： ? 以及我得到的输出。 ? 是否有其他方法可以将数据从pinpoint发送到personalize以启动营销活动。活动开始后，我可以根据文档通过活动发送数据。
浏览 35提问于2021-10-01得票数 1
回答已采纳
1回答
我将使用AWS SQS(常规队列，而不是FIFO)来处理不同的客户端指标。
我预计每秒大约有400条消息(最坏情况下).My消息将包含文件的S3位置。
我创建了一个应用程序，它将侦听我的SQS队列，并处理其中的消息。
我所说的过程是指：
read SQS message -> take S3 location from SQS message -> call S3 client -> Read S3 -> ->H19添加一些附加字段AWS Kinesis FirehosH111将数据从此文件发布到AWS Kinesis Firehos.
队列中的每个SQS消息也会
浏览 26提问于2018-11-27得票数 1
回答已采纳
是否有可能在转换后捕获lambda @edge请求到像kinesis这样的服务。
我想我也许可以写成json的云观察日志，然后以某种方式自动地将每一个条目写到“运动”中，也许是通过lambda。
这个是可能的吗？这将用于流量日志和身份匹配。
浏览 0提问于2017-11-10得票数 0
回答已采纳
1回答
我开发了一项服务，可以接收来自AWS/Kinesis的消息并对其进行处理。我希望有一个能够捕获处理故障的看门狗服务。在服务开始处理消息之前，它会向watchdog发送一条消息，在处理完消息之后，它会通知Watchdog处理成功。如果在一段超时时间后没有‘成功’消息，Watchdog应该触发一些事件。
问题是:哪个AWS服务(如果有的话)可以为我做这项工作？
浏览 0提问于2018-08-08得票数 1
我有多个AWS kinesis数据流/firehose和CSV格式的结构化数据。我需要使用运动数据分析对这些数据执行分析。但是如何将多个流合并为一个流呢？因为Kinesis数据分析仅从一个流中获取数据。数据流可以存在于不同的地域。
问题:如何将Kinesis数据流合并为一个用于Kinesis数据分析的数据流？
浏览 3提问于2020-08-25得票数 0
我正在尝试从lambda连接到我的RDS实例。我在本地编写了lambda，并在本地进行了测试，一切都运行得很好。我部署到lambda，突然它就不工作了。下面是我正在运行的代码，如果它有帮助，我将通过kinesis流调用lambda。
'use strict';
exports.handler = (event, context, handlerCallback) => {
console.log('Recieved request for kinesis events!');
console.log(event);
console
浏览 2提问于2016-06-01得票数 23
回答已采纳
1回答
Cocoa中的输入事件(如(void)mouseDown:(NSEvent *)theEvent和(void)keyDown:(NSEvent *)theEvent )是否线程安全，并与NSTimer事件触发同步？
我可以让NSTimer事件像触控输入事件一样访问相同的内存吗？这是线程安全的吗？
浏览 0提问于2013-06-29得票数 0
回答已采纳
1回答
在启用跟踪的情况下，我有少量Python函数，它们的开头如下：
import json
import boto3
from aws_xray_sdk.core import patch
from aws_xray_sdk.core import xray_recorder
patch(['boto3'])
def lambda_handler(event, context):
...
有了这个跟踪，每个Lambda函数本身都能工作，我可以看到通过boto3对DynamoDB或Kinesis的子服务调用。
，但是如何在一条跟踪中将各种Lambda函数连接在一起呢？，我正在
浏览 2提问于2020-03-31得票数 0
我正在写一个Angular应用程序，希望同时支持台式机/笔记本电脑和触摸设备。
对于我正在实现的一个功能，我希望能够区分用户是否点击或触摸了一个元素，并触发了不同的处理程序。
最简单的方法是什么？我在考虑在服务器中进行User-Agent检测，如果用户有触控设备，则返回不同的JS文件，但这似乎很糟糕。
浏览 0提问于2013-08-22得票数 1
我计划使用Kinesis消防软管将数据流到HTTP端点。HTTP端点由OIDC进行身份验证，这意味着它需要一个访问令牌来进行身份验证。但我找不到任何地方，我可以把一些逻辑，以获得访问令牌在消防水管。我是否必须使用Kinesis数据流并使用lambda作为使用者来完成这项工作？
浏览 3提问于2021-04-17得票数 1
回答已采纳
是否可以使用Kinesis SDK访问DynamoDBStreams服务定义的流？例如，使用C++，是否有可能获得有关添加的流的信息
$ aws dynamodb update-table --stream-specification ...
使用
Aws::Kinesis::KinesisClient::DescribeStream()
？(这将意味着“切换”服务Kinesis目标。AFAIK这是不可能的，因为Kinesis和DynamoDBStreams服务是分离的，但是它们有共同的概念点。)
浏览 0提问于2017-04-27得票数 0
因此，我正在尝试在Amazon AWS中创建一个简单的管道。我想使用由触发状态机的第一个lambda的流生成的数据来执行一个步骤函数
我想要做的是以下几点。
输入数据由AWS Kinesis流式传输
此Kinesis流用作执行和写入S3存储桶的lambda1的触发器。
这将触发(使用步骤函数)一个lambda2，它将从给定的存储桶中读取内容，并将其写入另一个存储桶
现在，我想使用Amazon Step函数实现一个状态机。我已经创建了非常简单的状态机。
{
"Comment": "Linear step function test",
"Sta
浏览 2提问于2017-08-20得票数 2
回答已采纳
我想在不使用EC2实例的情况下处理我的Kinesis流数据？有没有可能做到这一点。通过Lambda函数等？
浏览 12提问于2019-01-18得票数 1
我正在实现一个涉及SQS的解决方案，它触发一个Lambda函数，使用第三方API来执行一些操作。第三方API有每秒请求数的限制，所以我想将Lambda函数处理的SQS消息的数量限制为类似的速率。
有没有办法限制SQS上每秒可见的消息数量或Lambda函数每秒调用的数量？
编辑过的
在关于AWS Kinesis的评论中给出了一些见解之后:由于Kinesis has的行为会在达到任何阈值时触发lambda执行，因此没有通过处理Kinesis参数批处理窗口、批处理大小和有效负载大小的精益解决方案：*给定N=我可以通过第三方api执行的每秒最大请求数。*配置批处理窗口=1秒，批处理大小为N，back
浏览 2提问于2020-06-06得票数 1
1回答
我有一个使用案例，其中有一个Kinesis流(在不同的AWS帐户中管理)，是否可以使用可能在我们的帐户(跨帐户)中触发lambda的事件来配置此流？我知道在Kinesis events的情况下，lambda会轮询Kinesis流，那么它的工作原理是否类似于帐户A中的S3事件(基于推送)如何触发帐户B中的lambda？此外，这两个资源是否应该位于相同的区域才能正常工作？
浏览 0提问于2018-08-04得票数 0
1回答
我正在进行跨平台触摸活动。(刷卡等)他们在安卓设备上工作，但对iPad来说，触屏启动事件是两次发射。
this.element.addEventListener('touchstart', mousedown, false);
var mousedown = function(event) {
// Finger Press
event.preventDefault();
_this.inGesture = true;
_this._originalX = (event.touches) ? event.touches[0].pageX : e
浏览 8提问于2012-03-20得票数 7
我的网站运行的脚本只对鼠标有用，并且必须在触摸屏上禁用，因为它不能与它们一起工作。
因此，为了解决这个问题，我使用了以下命令：
var deviceAgent = navigator.userAgent.toLowerCase();
var isTouchDevice = Modernizr.touch ||
(deviceAgent.match(/(iphone|ipod|ipad)/) ||
deviceAgent.match(/(android)/) ||
deviceAgent.match(/(iemobile)/) ||
deviceAgent.match(/iphone/
浏览 2提问于2015-03-05得票数 2
1回答
我是AWS生态系统的新手。我正在构建一个(接近)实时系统，其中数据来自外部API。API每10秒更新一次，因此我希望在新数据出现时立即使用和填充我的Kinesis管道。但是，我不确定为此使用了哪种工具。我做了一个小小的研究，我想我有两个选择：
每10秒触发一次的AWS lambda，并将数据放在Kinesis上。
AWS StepFunction
给定用例的标准方法是什么？
浏览 1提问于2021-06-09得票数 1
1回答
从浏览器流到Amazon动态视频
、、、、
我正在开发一个web应用程序，它可以从摄像头上捕获视频，并将流保存到Amazon。我提出的第一种方法是getUserMedia / mediaRecorder / XMLHttpRequest，它将块的MKV发布到我的unix服务器(而不是AWS)，在这里，简单的PHP后端代理可以通过putMedia将MKV传输到Kinsis.MKV。
这应该是可行的，但是来自用户的所有媒体流都将通过我的服务器，这可能成为瓶颈。据我所知，由于跨源问题，无法将块mkv直接从浏览器发送到Amazon。如果我错了就纠正我或者有办法解决这个问题。
还有一件事我觉得我错过了-- WebRTC。XHR给人的感觉有点像20
浏览 1提问于2019-03-28得票数 2
我想使用lambda函数转换AWS的运动流数据，然后使用AWS消防软管将其传递到S3。但是，我总是遇到这样的问题：errorCode":"Lambda.FunctionError"，“errorMessage”：“Lambda函数已被成功调用，但它返回了一个错误结果”。
这是lambda_function。
import base64
import json
def lambda_handler(event, context):
output = []
for record in event['Records']:
#
浏览 11提问于2020-08-02得票数 3
回答已采纳
1回答
从下面这个问题开始，
DynamoDB -> DynamoDBStreams --> Lambda函数-> Kinesis > Redshift。
如何配置我的Kinesis函数以获取Lambda函数源？
我创建了一个DynamoDB表(购买销售)，并添加了DynamoDB流。然后，我配置了Lambda函数以拾取DynamoDB流。我的问题是如何配置Kinesis来获取Lambda函数源？我知道如何配置Lambda转换，但是我想作为源代码来选择。不确定如何配置下面的Direct源代码。
谢谢,
执行了以下步骤：
浏览 1提问于2018-06-11得票数 0
回答已采纳
1回答
超过运动速率极限造成的云形成失效
、、、、
我们有一个AWS Lambda SAM模板，在Cloudformation堆栈创建/更新过程中偶尔会失败，原因是：
Invalid request provided: Received Exception while reading from provided stream. Rate exceeded for shard shardId-000000000000
在SAM模板中，10个Lambda函数(Lambda的Kinesis源)被附加到同一个带有10个碎片的Kinesis中。
有谁会引起这个问题吗？我不认为有任何限制的数量的Lambda连接到一个单一的动态流
浏览 13提问于2021-12-21得票数 0
回答已采纳
1回答
我正在尝试使用类似于https://github.com/aws-samples/amazon-kinesis-learning的Kinesis客户端库来使用Kinesis数据流。但在这个例子中，他们安排了这个过程。我想在没有调度的情况下使用传入的记录。 我不想用DynamoDB，cloudWatch。期望一个简单的消费者使用流中的记录 有没有使用java在没有调度程序的情况下处理记录的方法
浏览 17提问于2020-07-15得票数 0
我目前有一个将数据从DDB Streams复制到Kinesis数据流的用例(只是为了增加数据保留期)。与Kinesis数据流相比，DDB Streams的24小时保留期最长可达7天。 因此，我在考虑使用lambda将项目从DDB Streams复制到Kinesis数据流，但我不确定当我执行复制时，排序/重复记录的情况是否会起作用，因为我猜“消费者”故障(即Lambda故障可能导致流记录无序交付到DynamoDB )，并且Kinesis数据流中可能存在重复记录？是否有AWS客户构建的解决方案来处理此问题或解决此问题？ 此外，我选择Kinesis数据流/ DDB流的背后原因是因为我将在流之外使用
浏览 7提问于2020-01-04得票数 0
1回答
我正在使用AWS Kinesis，它包含客户事务。在开始处理事务之前，我希望将事务备份到S3中。如何在不运行任何Lambda或其他计算组件的情况下，使用裸动态消防软管来备份Kinesis中的事务？
浏览 1提问于2016-11-21得票数 1
回答已采纳
2回答
将大约3K对象(文件)加载到S3。有一个事件触发了加载到该S3桶上的每个文件。
Lambda只接收大约300个对象的事件触发器。如果我重试(从S3移回S3)，它会为另外400个对象生成事件，其余的事件甚至没有到达lambda。
我在这里缺少了什么，如何对创建的对象进行缩放？
var async = require('async');
浏览 1提问于2017-11-06得票数 7
回答已采纳
2回答
我有一个写入DynamoDB表的应用程序，我正在尝试让Kinesis执行聚合，然后将聚合的数据写入另一个DynamoDB表。
在我的DynamoDB表上启用了Streams，并且在流上有一个Lamdba触发器，如下所示：
'use strict';
var AWS = require('aws-sdk');
var kinesis = new AWS.Kinesis();
exports.handler = (event, context, callback) => {
event.Records.forEach((record) =>
浏览 1提问于2016-10-26得票数 3
我正在使用AWS (配置为Serverless框架)，我使用的是batchSize of 1。
processEvents:
handler: ...
events:
- stream:
type: kinesis
batchSize: 1
arn:
Fn::GetAtt: [KinesisStream, Arn]
例如，在读取下一批之前，是否有一种方法将超时设置为20秒？
我希望在每个lambda执行之前有一个时间延迟，基本上从流中提取一个记录。
谢谢!
浏览 1提问于2020-02-05得票数 1
1回答
问题:从Dynamo获取2000项并处理(从100项创建POST req )--按批处理(批大小= 100)。
问题:我是否可以通过AWS中的任何配置来实现它？
PS :我已经配置了一个cron计划来运行我的Lambda函数。我在用Java。我已经开发了多线程应用程序，它可以同步完成，但这最终大大增加了我的计算时间。
浏览 1提问于2017-01-29得票数 1
回答已采纳
有办法在动态计时器上触发AWS Lambda吗？目前，我正在利用预定的事件来触发lambda，但是这是一个固定的计时器。是否有一种方法可以动态地设置从Lambda内部触发Lambda的时间？
这里的想法是，这个Lambda执行特定的检查并执行代码，以知道它应该在什么时候运行(因为我只希望这个lambda在需要的时候运行)。我希望1)确定下一次它需要运行的时间，2)从Lambda代码中设置时间。
我看到有很多资源用于触发Lambda函数(SNS、Kinesis等)，但我似乎找不到一个动态启动的好方法。
浏览 12提问于2017-01-09得票数 20
回答已采纳
我正试图在AWS服务之上构建一条数据收集管道。总体架构如下所示；
总之，系统应该从API网关(1)获取事件(每个事件有一个请求)，并且数据应该写入Kinesis (2)。
我期望每秒有100 k的事件发生。我的问题与Lambda函数的KPL使用有关。在步骤2中，我计划使用KPL编写Lambda方法，以便在Kinesis上编写具有高吞吐量的事件。但我不确定是否可能因为separately分别为每个事件调用lambda函数。
在这样的体系结构中使用KPL是可能/合理的，还是我应该使用Kinesis来代替？
1 2
浏览 11提问于2017-07-03得票数 0
回答已采纳
2回答
我需要在我的Lambda函数中添加基于SNS的触发器，但是只表示DynamoDB、Kinesis、SQS。
基于SNS、S3等的触发器的aws lambda create-event-source-mapping命令在--event-source-arn中失败
在调用InvalidParameterValueException操作时发生了错误:不可识别的事件源，必须是CreateEventSourceMapping、dynamodb流或sqs。不支持源arn
但是，可以通过AWS控制台来完成这些任务。
有什么想法吗？
浏览 0提问于2020-03-12得票数 0
2回答
我有从SNS发布消息到kinesis的要求。我发现，直接订阅SNS/SQS是不可能的。我需要编写lambda来从SNS获取，并将其发布到kinesis。有没有其他方法可以直接将记录从SNS发布到kinesis？谢谢
浏览 1提问于2018-05-21得票数 9
回答已采纳
我已经读过一些关于kinesis、shard和多个消费者的问题，但我仍然不明白它是如何工作的。
我的用例:我有一个只有一个分片的kinesis流。我想使用不同的lambda函数来使用这个分片，每个函数都是独立的。就像每个lambda函数都有自己的分片迭代器一样。
有可能吗？设置多个lambda消费者(基于流)从同一个流/分片读取？
浏览 2提问于2017-04-14得票数 5
我有一个Lambda，它每5分钟重复运行一次。它为每个用户执行一次数据处理任务(查询第三方API并处理响应)。这每5分钟产生一次数据尖峰。
我想每秒钟将数据的激增转化为均匀的数据传播。有什么方法可以在5分钟内将重复的任务扩展到多个Lambda调用中，以获得更均匀的数据传播？
我的目标是在一段时间内得到均匀分布的数据输出，这样我就可以像实时流数据一样将其导入AWS Kinesis。
编辑：
现在，我的Lambda通过Cloudwatch事件每5分钟运行一次。它查询我的服务器以获得用户API密钥，然后查询第三方API，处理结果并将其存储在DynamoDB中。
我希望将负载均匀地分散到5分钟以上，这
浏览 0提问于2019-08-07得票数 0
2回答
我们正在使用AWS设计一个无服务器服务。
整体结构是API-gateway -> lambda L1 -> kinesis ->后端
接口网关-> lambda L1为proxy模式。例如，APIG将把整个有效负载传输到lambda，包括客户端帐户id等上下文
我们希望在内部有一个重试策略，以防后端由于某种原因导致处理失败。对于内部重试机制，我们希望使用相同的请求再次触发λL1。
为此，我们有以下解决方案：
每当L1网关请求触发lambda接口时，我们都会将整个请求存储在S3中。在重试期间，我们将有一个单独的重试λL2，它从s3下载相同的请求，读取它，并使用相同的有效负
浏览 0提问于2021-02-09得票数 0
AWS Lambda支持Kinesis和DynamoDB事件源的并行化因子。但是它不支持MSK。我们是否可以创建Lambda函数的保留并发，以及并发使用来自MSK主题的内容是否有帮助
浏览 3提问于2021-02-03得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
