2

我有一个从 Dynamodb 流中读取的 lambda 函数。我有从同一个 AWS 账户中的另一个堆栈导出的 Dynamodb 流 ARN。现在,在 Lambda 中添加 eventSource 时,它​​从 Table 构造中询问。

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-streams

但我有流 ARN。有什么办法可以利用它来添加事件源。或者我必须导出表本身?

4

1 回答 1

6

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

你仍然可以通过直接使用EventSourceMapping类来达到你的目标@aws-cdk/aws-lambda

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>/*');
);
于 2019-04-20T14:13:56.120 回答