Kinesis - Amazon Serverless Application Model
语法属性示例
Amazon Web Services 文档中描述的 Amazon Web Services 服务或功能可能因区域而异。要查看适用于中国区域的差异，请参阅中国的 Amazon Web Services 服务入门。

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

Kinesis

描述Kinesis事件源类型。有关更多信息，请参阅 。使用Amazon Lambda使用 Amazon Kinesis中的Amazon Lambda开发人员指南.

Amazon SAM生成AWS::Lambda::EventSourceMapping设置此事件类型时的资源。

语法

要在您的中声明此实体Amazon Serverless Application Model(Amazon SAM）模板，请使用以下语法。

属性

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) 主题目标。

类型：DestinationConfig

必需：否

Amazon CloudFormation兼容性：此属性将直接传递给DestinationConfig一个的财产AWS::Lambda::EventSourceMapping资源。

Enabled

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

类型：Boolean

必需：否

Amazon CloudFormation兼容性：此属性将直接传递给Enabled一个的财产AWS::Lambda::EventSourceMapping资源。

FilterCriteria

定义用于确定 Lambda 是否应处理事件的条件的对象。有关更多信息，请参阅 。Amazon Lambda筛选事件中的Amazon Lambda开发人员指南.

类型：FilterCriteria

必需：否

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"]}'