Skip to content

Instantly share code, notes, and snippets.

@ziedbentahar
Created April 18, 2023 08:25
const targetPolicy = new PolicyDocument({
statements: [
new PolicyStatement({
resources: [targetStepFunction.stateMachineArn],
actions: ["states:StartExecution"],
effect: Effect.ALLOW,
}),
],
});
const sourcePolicy = new PolicyDocument({
statements: [
new PolicyStatement({
resources: [soureTable.tableStreamArn!],
actions: [
"dynamodb:DescribeStream",
"dynamodb:GetRecords",
"dynamodb:GetShardIterator",
"dynamodb:ListStreams",
],
effect: Effect.ALLOW,
}),
],
});
const pipeRole = new Role(this, "role", {
assumedBy: new ServicePrincipal("pipes.amazonaws.com"),
inlinePolicies: {
sourcePolicy,
targetPolicy,
},
});
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment