Kinesis - AWS Serverless Application Model
AWS 文档中描述的 AWS 服务或功能可能因区域而异。要查看适用于中国区域的差异,请参阅中国的 AWS 服务入门

本文属于机器翻译版本。若本译文内容与英语原文存在差异,则一律以英文原文为准。

Kinesis

描述 Kinesis 事件来源类型。

AWS SAM 会生成 ASTA::Lambda::Event源映射 资源。

语法

在你的 AWS 无服务器应用程序模型 (AWS SAM)模板,使用以下语法。

属性

BatchSize

要在单个批次中检索的最大项目数。

类型:整数

必需: 否

默认值:-100

AWS CloudFormation 相容性: 此属性直接传递给 BatchSize 特性 AWS::Lambda::EventSourceMapping 资源。

最低: 1

最高: 10000

BisectBatchOnFunctionError

如果函数返回错误,将批处理拆分成两个,然后重试。

类型:布尔值

必需: 否

AWS CloudFormation 相容性: 此属性直接传递给 BisectBatchOnFunctionError 特性 AWS::Lambda::EventSourceMapping 资源。

DestinationConfig

安 Amazon SQS 队列或 Amazon SNS 被丢弃记录的主题目的地。

类型DestinationConfig

必需: 否

AWS CloudFormation 相容性: 此属性直接传递给 DestinationConfig 特性 AWS::Lambda::EventSourceMapping 资源。

Enabled

禁用事件源映射以暂停轮询和调用。

类型:布尔值

必需: 否

AWS CloudFormation 相容性: 此属性直接传递给 Enabled 特性 AWS::Lambda::EventSourceMapping 资源。

MaximumBatchingWindowInSeconds

在调用函数之前收集记录的最长时间(以秒为单位)。

类型:整数

必需: 否

AWS CloudFormation 相容性: 此属性直接传递给 MaximumBatchingWindowInSeconds 特性 AWS::Lambda::EventSourceMapping 资源。

MaximumRecordAgeInSeconds

Lambda发送给函数处理的记录的最长年龄。

类型:整数

必需: 否

AWS CloudFormation 相容性: 此属性直接传递给 MaximumRecordAgeInSeconds 特性 AWS::Lambda::EventSourceMapping 资源。

MaximumRetryAttempts

在函数返回错误时重试的最大次数。

类型:整数

必需: 否

AWS CloudFormation 相容性: 此属性直接传递给 MaximumRetryAttempts 特性 AWS::Lambda::EventSourceMapping 资源。

ParallelizationFactor

从每个分片同时处理的批次数量。

类型:整数

必需: 否

AWS CloudFormation 相容性: 此属性直接传递给 ParallelizationFactor 特性 AWS::Lambda::EventSourceMapping 资源。

StartingPosition

在流中开始读取数据的位置。

支持的值 TRIM_HORIZON, LATEST, AT_TIMESTAMP.

类型:字符串

必需: 是

AWS CloudFormation 相容性: 此属性直接传递给 StartingPosition 特性 AWS::Lambda::EventSourceMapping 资源。

Stream

数据流的ARN或流消费者。

类型:字符串

必需: 是

AWS CloudFormation 相容性: 此属性直接传递给 EventSourceArn 特性 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