AWS CloudFormation
User Guide (API Version 2010-05-15)
AWS 服务或AWS文档中描述的功能,可能因地区/位置而异。请点击 Amazon AWS 入门,可查看中国地区的具体差异

AWS::Lambda::EventSourceMapping

AWS::Lambda::EventSourceMapping 资源为 AWS Lambda (Lambda) 函数指定作为事件源的流。流可以是 Kinesis 流,也可以是 Amazon DynamoDB (DynamoDB) 流。将记录发布到流时,Lambda 会调用关联的函数。有关更多信息,请参阅 AWS Lambda Developer Guide 中的 CreateEventSourceMapping

语法

要在 AWS CloudFormation 模板中声明此实体,请使用以下语法:

JSON

{ "Type" : "AWS::Lambda::EventSourceMapping", "Properties" : { "BatchSize" : Integer, "Enabled" : Boolean, "EventSourceArn" : String, "FunctionName" : String, "StartingPosition" : String } }

YAML

Type: "AWS::Lambda::EventSourceMapping" Properties: BatchSize: Integer Enabled: Boolean EventSourceArn: String FunctionName: String StartingPosition: String

属性

BatchSize

调用您的函数时,Lambda 从事件源检索的最大记录数。您的函数将接收具有所有已检索记录的事件。有关默认值和有效值的信息,请参阅 AWS Lambda Developer Guide 中的 CreateEventSourceMapping

Required: No

Type: Integer

更新要求无需中断

Enabled

指示 Lambda 何时开始轮询事件源。

Required: No

Type: Boolean

更新要求无需中断

EventSourceArn

作为事件源的 Kinesis 或 DynamoDB 流的 Amazon 资源名称 (ARN)。添加到此流的所有记录均可调用 Lambda 函数。有关更多信息,请参阅 AWS Lambda Developer Guide 中的 CreateEventSourceMapping

Required: Yes

Type: String

更新要求替换

FunctionName

Lambda 在流上检测到事件时调用的 Lambda 函数的名称或 ARN。

Required: Yes

Type: String

更新要求无需中断

StartingPosition

Lambda 开始读取的流的位置。有关有效值的信息,请参阅 AWS Lambda Developer Guide 中的 CreateEventSourceMapping

Required: Yes

Type: String

更新要求替换

返回值

Ref

当该资源的逻辑 ID 提供给 Ref内部函数时,Ref 将返回资源名称。

有关使用 Ref 功能的更多信息,请参阅参考

示例

下面的示例将 Kinesis 流与 Lambda 函数关联。

JSON

"EventSourceMapping": { "Type": "AWS::Lambda::EventSourceMapping", "Properties": { "EventSourceArn" : { "Fn::Join" : [ "", [ "arn:aws:kinesis:", { "Ref" : "AWS::Region" }, ":", { "Ref" : "AWS::AccountId" }, ":stream/", { "Ref" : "KinesisStream" }] ] }, "FunctionName" : { "Fn::GetAtt" : ["LambdaFunction", "Arn"] }, "StartingPosition" : "TRIM_HORIZON" } }

YAML

EventSourceMapping: Type: "AWS::Lambda::EventSourceMapping" Properties: EventSourceArn: Fn::Join: - "" - - "arn:aws:kinesis:" - Ref: "AWS::Region" - ":" - Ref: "AWS::AccountId" - ":stream/" - Ref: "KinesisStream" FunctionName: Fn::GetAtt: - "LambdaFunction" - "Arn" StartingPosition: "TRIM_HORIZON"

本页内容: