Merge pull request #21285 from drewmullen/f-aws-vpc-flow-logs-parquet

enhancement: aws/resource_aws_vpc_flow_log destination_options parquet

.changelog/21285.txt

@@ -0,0 +1,3 @@
+```release-note:enhancement
+resource/aws_vpc_flow_log: Add `destination_options` block argument which can now enable parquet log file format
+```

aws/internal/service/ec2/errors.go

@@ -94,6 +94,10 @@ const (
 	ErrCodeInvalidPermissionNotFound  = "InvalidPermission.NotFound"
 )
 
+const (
+	ErrCodeInvalidFlowLogIdNotFound = "InvalidFlowLogId.NotFound"
+)
+
 const (
 	ErrCodeInvalidPlacementGroupUnknown = "InvalidPlacementGroup.Unknown"
 )

aws/internal/service/ec2/finder/finder.go

@@ -883,6 +883,28 @@ func VpnGatewayByID(conn *ec2.EC2, id string) (*ec2.VpnGateway, error) {
 	return output.VpnGateways[0], nil
 }
 
+func FlowLogByID(conn *ec2.EC2, id string) (*ec2.FlowLog, error) {
+	input := &ec2.DescribeFlowLogsInput{
+		FlowLogIds: aws.StringSlice([]string{id}),
+	}
+
+	output, err := conn.DescribeFlowLogs(input)
+
+	if err != nil {
+		return nil, err
+	}
+
+	if output == nil || len(output.FlowLogs) == 0 || output.FlowLogs[0] == nil {
+		return nil, tfresource.NewEmptyResultError(input)
+	}
+
+	if count := len(output.FlowLogs); count > 1 {
+		return nil, tfresource.NewTooManyResultsError(count, input)
+	}
+
+	return output.FlowLogs[0], nil
+}
+
 func ManagedPrefixListByID(conn *ec2.EC2, id string) (*ec2.ManagedPrefixList, error) {
 	input := &ec2.DescribeManagedPrefixListsInput{
 		PrefixListIds: aws.StringSlice([]string{id}),