1curl 169.254.169.254/latest/meta-data/sts-credential

1import (
2    "fmt"
3    "github.com/baidubce/bce-sdk-go/auth"         //导入认证模块
4    "github.com/baidubce/bce-sdk-go/services/bos" //导入BOS服务模块
5    "github.com/baidubce/bce-sdk-go/services/sts" //导入STS服务模块
6)
7
8func main() {
9    
10    // 获取实例里的临时身份凭证
11    accessKeyId = getAccessKeyId()
12    secretAccessKey = getSecretAccessKey()
13    sessionToken = getSessionToken()
14
15    bosClient, err := bos.NewClient(accessKeyId, secretAccessKey, sessionToken)
16    if err != nil {
17        fmt.Println("create bos client failed:", err)
18        return
19    }
20    stsCredential, err := auth.NewSessionBceCredentials(
21        accessKeyId,
22        secretAccessKey,
23        sessionTokenn)
24    if err != nil {
25        fmt.Println("create sts credential object failed:", err)
26        return
27    }
28    bosClient.Config.Credentials = stsCredential
29
30    // 提供Bucket和Object，直接获取一个对象
31    res, err := bosClient.BasicGetObject(bucketName, objectName)
32
33    // 获取ObjectMeta
34    meta := res.ObjectMeta
35
36    // 获取Object的读取流（io.ReadCloser）
37    stream := res.Body
38
39    // 确保关闭Object读取流
40    defer stream.Close()
41
42    // 调用stream对象的Read方法处理Object
43    ...
44}