我有一个在 S3 中存储数据的 firehose 传输流。但是,我想在传输流中添加一个 lambda 函数以在存储之前解析数据。
为此,除了 kinesis 策略之外,我是否还需要 IAM 策略?
回答1
您需要将 processing_configuration
添加到 type = "Lambda"
的 aws_kinesis_firehose_delivery_stream
中。为此,您还需要将 RoleArn
添加到 IAM 角色,您的 firehose 将使用该角色调用该函数。该角色必须包含以下 IAM 策略:
{
"Sid": "",
"Effect": "Allow",
"Action": [
"lambda:InvokeFunction",
"lambda:GetFunctionConfiguration"
],
"Resource": "<your-lambda-function-arn>"
}