本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。
Kinesis
描述Kinesis事件源类型的对象。有关更多信息,请参阅《Amazon Lambda开发者指南》中的 “在 Amazon LambdaAmazon Kinesis 上使用”。
Amazon SAM设置此事件类型时生成AWS::Lambda::EventSourceMapping资源。
语法
要在Amazon Serverless Application Model (Amazon SAM) 模板中声明此实体,请使用以下语法。
YAML
BatchSize:IntegerBisectBatchOnFunctionError:BooleanDestinationConfig:DestinationConfigEnabled:BooleanFilterCriteria:FilterCriteriaFunctionResponseTypes:ListMaximumBatchingWindowInSeconds:IntegerMaximumRecordAgeInSeconds:IntegerMaximumRetryAttempts:IntegerParallelizationFactor:IntegerStartingPosition:StringStartingPositionTimestamp:DoubleStream:StringTumblingWindowInSeconds:Integer
属性
-
BatchSize -
要在单个批次中检索的最大项目数。
类型:整数
必需:否
默认值:100
Amazon CloudFormation兼容性:此属性直接传递给
AWS::Lambda::EventSourceMapping资源的BatchSize属性。最小值:
1最大值:
10000 -
BisectBatchOnFunctionError -
如果函数返回错误,则将批并重试。
类型:布尔值
必需:否
Amazon CloudFormation兼容性:此属性直接传递给
AWS::Lambda::EventSourceMapping资源的BisectBatchOnFunctionError属性。 -
DestinationConfig -
Amazon Simple Queue Service (Amazon SQS) 或存放丢弃记录的Simple Notification Service (Amazon SNS) otification Service
必需:否
Amazon CloudFormation兼容性:此属性直接传递给
AWS::Lambda::EventSourceMapping资源的DestinationConfig属性。 -
Enabled -
禁用事件源映射以暂停轮询和调用。
类型:布尔值
必需:否
Amazon CloudFormation兼容性:此属性直接传递给
AWS::Lambda::EventSourceMapping资源的Enabled属性。 -
FilterCriteria -
定义用于确定 Lambda 是否应处理事件的标准的对象。有关更多信息,请参阅《Amazon Lambda开发者指南》中的Amazon Lambda事件筛选。
必需:否
Amazon CloudFormation兼容性:此属性直接传递给
AWS::Lambda::EventSourceMapping资源的FilterCriteria属性。 -
FunctionResponseTypes -
当前应用于事件源映射的响应类型列表。有关更多信息,请参阅Amazon Lambda开发者指南中的报告批处理项目故障。
有效值:
ReportBatchItemFailures类型:清单
必需:否
Amazon CloudFormation兼容性:此属性直接传递给
AWS::Lambda::EventSourceMapping资源的FunctionResponseTypes属性。 -
MaximumBatchingWindowInSeconds -
在调用函数之前收集记录的最长时间(以秒为单位)。
类型:整数
必需:否
Amazon CloudFormation兼容性:此属性直接传递给
AWS::Lambda::EventSourceMapping资源的MaximumBatchingWindowInSeconds属性。 -
MaximumRecordAgeInSeconds -
Lambda 发送到函数以进行处理的记录的最长期限。
类型:整数
必需:否
Amazon CloudFormation兼容性:此属性直接传递给
AWS::Lambda::EventSourceMapping资源的MaximumRecordAgeInSeconds属性。 -
MaximumRetryAttempts -
在函数返回错误时重试的最大次数。
类型:整数
必需:否
Amazon CloudFormation兼容性:此属性直接传递给
AWS::Lambda::EventSourceMapping资源的MaximumRetryAttempts属性。 -
ParallelizationFactor -
要从每个分区中同时处理的批并数。
类型:整数
必需:否
Amazon CloudFormation兼容性:此属性直接传递给
AWS::Lambda::EventSourceMapping资源的ParallelizationFactor属性。 -
StartingPosition -
在流中开始读取数据的位置。
-
AT_TIMESTAMP— 指定开始读取记录的时间。 -
LATEST— 仅读取新记录。 -
TRIM_HORIZON— 处理所有可用的记录。
有效值:
AT_TIMESTAMP|LATEST|TRIM_HORIZON类型:字符串
必需:是
Amazon CloudFormation兼容性:此属性直接传递给
AWS::Lambda::EventSourceMapping资源的StartingPosition属性。 -
-
StartingPositionTimestamp -
开始读取的时间(以 Unix 时间秒为单位。定义
StartingPositionTimestamp何时指定StartingPosition为AT_TIMESTAMP。类型:双精度
必需:否
Amazon CloudFormation兼容性:此属性直接传递给
AWS::Lambda::EventSourceMapping资源的StartingPositionTimestamp属性。 -
Stream -
数据流的 Amazon Rcce (ARN)。
类型:字符串
必需:是
Amazon CloudFormation兼容性:此属性直接传递给
AWS::Lambda::EventSourceMapping资源的EventSourceArn属性。 -
TumblingWindowInSeconds -
处理窗口的持续时间(以秒为单位)。有效范围为 1 到 900(15 分钟)。
有关更多信息,请参阅《Amazon Lambda开发者指南》中的 Tumbling Windows。
类型:整数
必需:否
Amazon CloudFormation兼容性:此属性直接传递给
AWS::Lambda::EventSourceMapping资源的TumblingWindowInSeconds属性。
示例
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"]}'