本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。
Kinesis
描述Kinesis
事件源类型。有关更多信息,请参阅 。使用Amazon Lambda使用 Amazon Kinesis中的Amazon Lambda开发人员指南.
Amazon SAM生成AWS::Lambda::EventSourceMapping设置此事件类型时的资源。
语法
要在您的中声明此实体Amazon Serverless Application Model(Amazon SAM)模板,请使用以下语法。
YAML
BatchSize:
Integer
BisectBatchOnFunctionError:Boolean
DestinationConfig:DestinationConfig
Enabled:Boolean
FilterCriteria:FilterCriteria
FunctionResponseTypes:List
MaximumBatchingWindowInSeconds:Integer
MaximumRecordAgeInSeconds:Integer
MaximumRetryAttempts:Integer
ParallelizationFactor:Integer
StartingPosition:String
Stream:String
TumblingWindowInSeconds:Integer
属性
-
BatchSize
-
要在单个批次中检索的最大项目数。
类型:整数
必需:否
默认值:100
Amazon CloudFormation兼容性:此属性将直接传递给
BatchSize
一个的财产AWS::Lambda::EventSourceMapping
资源。最低:
1
最高:
10000
-
BisectBatchOnFunctionError
-
如果函数返回错误,则将批次拆分为两批并重试。
类型:Boolean
必需:否
Amazon CloudFormation兼容性:此属性将直接传递给
BisectBatchOnFunctionError
一个的财产AWS::Lambda::EventSourceMapping
资源。 -
DestinationConfig
-
用于丢弃记录的 Amazon Simple Queue Service (Amazon SQS) 队列或 Amazon Simple Notification Service (Amazon SNS) 主题目标。
必需:否
Amazon CloudFormation兼容性:此属性将直接传递给
DestinationConfig
一个的财产AWS::Lambda::EventSourceMapping
资源。 -
Enabled
-
禁用事件源映射以暂停轮询和调用。
类型:Boolean
必需:否
Amazon CloudFormation兼容性:此属性将直接传递给
Enabled
一个的财产AWS::Lambda::EventSourceMapping
资源。 -
FilterCriteria
-
定义用于确定 Lambda 是否应处理事件的条件的对象。有关更多信息,请参阅 。Amazon Lambda筛选事件中的Amazon Lambda开发人员指南.
必需:否
Amazon CloudFormation兼容性:此属性将直接传递给
FilterCriteria
一个的财产AWS::Lambda::EventSourceMapping
资源。 -
FunctionResponseTypes
-
当前应用于事件源映射的响应类型的列表。有关更多信息,请参阅 。报告批处理项目失败中的Amazon Lambda开发人员指南.
有效值:
ReportBatchItemFailures
类型:List
必需:否
Amazon CloudFormation兼容性:此属性将直接传递给
FunctionResponseTypes
一个的财产AWS::Lambda::EventSourceMapping
资源。 -
MaximumBatchingWindowInSeconds
-
在调用函数之前收集记录的最长时间(以秒为单位)。
类型:整数
必需:否
Amazon CloudFormation兼容性:此属性将直接传递给
MaximumBatchingWindowInSeconds
一个的财产AWS::Lambda::EventSourceMapping
资源。 -
MaximumRecordAgeInSeconds
-
Lambda 发送到函数以进行处理的记录的最长期限。
类型:整数
必需:否
Amazon CloudFormation兼容性:此属性将直接传递给
MaximumRecordAgeInSeconds
一个的财产AWS::Lambda::EventSourceMapping
资源。 -
MaximumRetryAttempts
-
在函数返回错误时重试的最大次数。
类型:整数
必需:否
Amazon CloudFormation兼容性:此属性将直接传递给
MaximumRetryAttempts
一个的财产AWS::Lambda::EventSourceMapping
资源。 -
ParallelizationFactor
-
要从每个分片中同时处理的批次数。
类型:整数
必需:否
Amazon CloudFormation兼容性:此属性将直接传递给
ParallelizationFactor
一个的财产AWS::Lambda::EventSourceMapping
资源。 -
StartingPosition
-
在流中开始读取数据的位置。
有效值:
TRIM_HORIZON
或LATEST
类型:字符串
必需:是
Amazon CloudFormation兼容性:此属性将直接传递给
StartingPosition
一个的财产AWS::Lambda::EventSourceMapping
资源。 -
Stream
-
数据流或流使用者的 Amazon 资源名称 (ARN)。
类型:字符串
必需:是
Amazon CloudFormation兼容性:此属性将直接传递给
EventSourceArn
一个的财产AWS::Lambda::EventSourceMapping
资源。 -
TumblingWindowInSeconds
-
处理窗口的持续时间(以秒为单位)。有效范围为 1 到 900(15 分钟)。
有关更多信息,请参阅 。滚动窗口中的Amazon Lambda开发人员指南.
类型:整数
必需:否
Amazon CloudFormation兼容性:此属性将直接传递给
TumblingWindowInSeconds
一个的财产AWS::Lambda::EventSourceMapping
资源。
示例
Kinesis 事件源
以下是 Kinesis 事件源示例。
YAML
Events: KinesisEvent: Type: Kinesis Properties: Stream: arn:aws:kinesis:us-east-1:123456789012:stream/my-stream StartingPosition: TRIM_HORIZON BatchSize: 10 Enabled: false FilterCriteria: Filters: - Pattern: '{"key": ["val1", "val2"]}'