in pipeline_utils.py [0:0]
def allow_s3(fcn_name,bucket_arn,account_num):
print('Adding permissions to Amazon S3 ...')
response = lambda_client.add_permission(
FunctionName=fcn_name,
StatementId=f"S3-Trigger-Lambda-{int(time.time())}",
Action='lambda:InvokeFunction',
Principal= 's3.amazonaws.com',
SourceArn=bucket_arn,
SourceAccount=account_num
)
print('SUCCESS: Successfully added permissions to Amazon S3!')