AWS开发工具包v2中适用于Go的AWS S3 SelectObjectContent未返回结果

亲爱的编程学习爱好者，如果你点开了这篇文章，说明你对《AWS开发工具包v2中适用于Go的AWS S3 SelectObjectContent未返回结果》很感兴趣。本篇文章就来给大家详细解析一下，主要介绍一下，希望所有认真读完的童鞋们，都有实质性的提高。

我很难让 selectobjectcontent 返回任何详细信息。令人沮丧的是查询在控制台中运行。

我的测试对象是一个存储在测试存储桶中的简单 json 文件：

{
  "name": "kevin",
  "role": "engineer",
  "color": "blue"
}

我的查询同样简单：

select * from s3object limit 5

以下是我为特定用例组装的函数：

func s3selectobjectcontent(bucket, region, objectkey, expression string) (*s3.selectobjectcontentoutput, error) {
    client := s3.newfromconfig(config, func(o *s3.options) {
        o.region = region
    })

    input := &s3.selectobjectcontentinput{
        bucket:         &bucket,
        key:            &objectkey,
        expression:     &expression,
        expressiontype: types.expressiontypesql,
        inputserialization: &types.inputserialization{
            json: &types.jsoninput{
                type: types.jsontypedocument,
                // type: types.jsontypelines
            },
            compressiontype: types.compressiontypegzip,
        },
        outputserialization: &types.outputserialization{
            json: &types.jsonoutput{
                recorddelimiter: aws.string("\n"),
            },
        },
    }

    result, err := client.selectobjectcontent(context.todo(), input)
    if err != nil {
        return nil, err
    }

    return result, nil
}

预先感谢您的帮助和想法。

我尝试调整 bucket 和 objectkey ...如果这些不正确，我会收到“未找到”消息。

我已确认我有权访问该存储桶，因为我可以使用 listobjectsv2 打印对象列表

我已经确认代码正在读取某些内容，因为如果我指向该文件的非 gzip 版本，它会抱怨该文件未压缩。

我的沙箱存储桶是私有的，并且具有最小存储桶策略：

{
    "version": "2012-10-17",
    "statement": [
        {
            "sid": "statement1",
            "effect": "allow",
            "principal": {
                "aws": "*"
            },
            "action": [
                "s3:getobject",
                "s3:listbucket"
            ],
            "resource": [
                "arn:aws:s3:::kkevin-testbucket",
                "arn:aws:s3:::kkevin-testbucket/*"
            ],
            "condition": {
                "stringequals": {
                    "aws:principalaccount": "123456789064"
                }
            }
        }
    ]
}

编辑：我可以确认此 cli 命令也可以工作并生成正确的输出：

aws s3api select-object-content \
    --bucket kkevin-testbucket \
    --key testfile.json.gz \
    --expression "select * from s3object limit 5" \
    --expression-type 'SQL' \
    --input-serialization '{"JSON": {"Type": "Document"}, "CompressionType": "GZIP"}' \
    --output-serialization '{"JSON": {}}' "output.json" \
    --profile sandbox

正确答案

您的代码是正确的。我向您的 s3selectobjectcontent 函数添加了一些打印语句，如下所示

stream := result.getstream()
defer stream.close()

for event := range stream.events() {
    v, ok := event.(*types.selectobjectcontenteventstreammemberrecords)
    if ok {
        value := string(v.value.payload)
        fmt.print(value)
    }
}

if err := stream.err(); err != nil {
    return nil, err
}

我得到了以下输出

{"Name":"Kevin","Role":"engineer","Color":"blue"}

今天关于《AWS开发工具包v2中适用于Go的AWS S3 SelectObjectContent未返回结果》的内容介绍就到此结束，如果有什么疑问或者建议，可以在golang学习网公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！