通过CDK中的ARN将eventSource添加到Lambda

Question

我有一个lambda函数，它读取Dynamodb流。我已将Dynamodb流ARN从同一AWS帐户中的另一个堆栈导出。现在，在Lambda中添加eventSource时，它从表构造中请求。

const function = new lambda.Function(...);
function.addEventSource(new DynamoEventSource(table, {
  startingPosition: lambda.StartingPosition.TrimHorizon
}));

裁判：https://awslabs.github.io/aws-cdk/refs/_aws-cdk_aws-lambda-event-sources.html#dynamodb-溪流

但是我有一条小溪。是否有任何方法可以利用此添加事件源。或者我必须导出表本身？

Answer 1

目前无法使用AWS CDK导入DynamoDB表。

您仍然可以通过直接使用@aws cdk/aws lambda中的EventSourceMapping类来实现您的目标：

import iam = require('@aws-cdk/aws-iam');
import lambda = require('@aws-cdk/aws-lambda');

const fn = new lambda.Function(...);

new lambda.EventSourceMapping(this, 'DynamoDBEventSource', {
  target: fn,
  batchSize: ...,
  eventSourceArn: <your stream arn>,
  startingPosition: lambda.StartingPosition.TrimHorizon
});

fn.addToRolePolicy(
  new iam.PolicyStatement()
    .addActions('dynamodb:DescribeStream', 'dynamodb:GetRecords', 'dynamodb:GetShardIterator', 'dynamodb:ListStreams')
    .addResource('<your stream arn>/*');
);