Terratest读取CloudWatch日志流遇类型错误：*string无法转string

问题背景 #

作为Golang新手，我正在编写Terratest测试以读取CloudWatch日志流，代码如下：

terraformOptions := terraform.WithDefaultRetryableErrors(t, &terraform.Options{
    // The path to where our Terraform code is located to give the folder name
    TerraformDir: "../../",

    // Variables to pass to our Terraform code using -var options
    Vars: map[string]interface{}{
        "dynamo_db_table_name": expectedTableName,
        "token": token,
        "aws_region": awsRegion,
        "access_key": accessKey,
        "secret_key": secretKey,
        "environment": environment,
    },

    // Environment variables to set when running Terraform
    EnvVars: map[string]string{
        "AWS_DEFAULT_REGION": awsRegion,
        "AWS_ACCESS_KEY_ID": accessKey,
        "AWS_SECRET_ACCESS_KEY": secretKey,
        "AWS_SESSION_TOKEN": token,
    },
    // Backend config to create state file in S3
    BackendConfig: map[string]interface{}{
        "bucket": bucketName,
        "key":    key,
        "region": awsRegion,
    },
})
// At the end of the test, run `terraform destroy` to clean up any resources that were created
defer terraform.Destroy(t, terraformOptions)

// This will run `terraform init` and `terraform apply` and fail the test if there are any errors
terraform.InitAndApply(t, terraformOptions)

client := aws.NewCloudWatchLogsClient(t, awsRegion)
cw_main_log_group_prefix := terraform.Output(t, terraformOptions, "main_cloudwatch_log_name")

groups, err := client.DescribeLogGroups(&cloudwatchlogs.DescribeLogGroupsInput{LogGroupNamePrefix: &cw_main_log_group_prefix})
// cw_prefix_not_exist_msg := fmt.Sprintf("CW Log group %s does not exists", cw_main_log_group_prefix)
if err != nil {
    assert.Error(t, errors.New("Error in "))
}

if len(groups.LogGroups) < 1 {
         assert.Error(t, errors.New(fmt.Sprintf("No log group found for %s", cw_main_log_group_prefix)))
}

group := groups.LogGroups[0]
fmt.Println(group)
streams, err := client.DescribeLogStreams(&cloudwatchlogs.DescribeLogStreamsInput{
        LogGroupName: group.LogGroupName,
        Descending:   awsSDK.Bool(true),
        OrderBy:      awsSDK.String("LastEventTime"),
})

if len(streams.LogStreams) < 1 {
      assert.Error(t, errors.New(fmt.Sprintf("No log streams found for %s", cw_main_log_group_prefix)))
}

stream := streams.LogStreams[0]
message, err := aws.GetCloudWatchLogEntriesE(t, awsRegion, stream.LogStreamName, cw_main_log_group_prefix)

报错信息 #

运行时出现类型不匹配错误：

cannot use stream.LogStreamName (variable of type *string) as type string in argument to aws.GetCloudWatchLogEntriesE

错误修复 #

错误原因是AWS SDK返回的stream.LogStreamName是指针类型（*string），而aws.GetCloudWatchLogEntriesE函数的参数需要的是基础string类型。只需要对指针进行解引用，获取其指向的字符串值即可：

修改最后一行代码为：

message, err := aws.GetCloudWatchLogEntriesE(t, awsRegion, *stream.LogStreamName, cw_main_log_group_prefix)

测试执行指导 #

• 权限验证：确保测试使用的AWS账号具备CloudWatch Logs相关权限，包括logs:DescribeLogGroups、logs:DescribeLogStreams、logs:GetLogEvents
• 资源等待机制：Terraform执行apply后，日志流可能不会立刻生成，建议添加重试逻辑。可以使用Terratest的retry.Do函数，在一段时间内重复检查日志流是否存在，避免因资源未就绪导致测试失败
• 错误处理优化：原代码中的错误处理不符合Terratest最佳实践：
  • 调用AWS API后，应该用assert.NoError(t, err, "错误描述")直接断言无错误，而非手动创建错误对象
  • 当未找到日志组/流时，使用assert.Fail(t, "自定义错误信息")更清晰，比如：

    if len(groups.LogGroups) < 1 {
        assert.Fail(t, fmt.Sprintf("未找到匹配前缀%s的日志组", cw_main_log_group_prefix))
    }
    

• 资源清理保障：确保defer terraform.Destroy(t, terraformOptions)正常执行，若测试中途崩溃，可手动执行terraform destroy清理资源；也可以使用Terratest的terraform.DestroyWithIdempotentRetry增加清理的可靠性
• 日志内容验证：获取日志条目后，添加断言验证预期内容，比如检查日志中是否包含特定业务关键词：

  assert.Contains(t, message, "预期日志内容关键词")
  

• 并行测试注意事项：若使用t.Parallel()并行执行测试，需确保每个测试用的资源（如日志组前缀、S3后端key）唯一，避免资源冲突

内容的提问来源于stack exchange，提问作者change198