in sample/open_file.go [25:71]
func main() {
flag.Parse()
if len(bucketName) == 0 {
flag.PrintDefaults()
log.Fatalf("invalid parameters, bucket name required")
}
if len(region) == 0 {
flag.PrintDefaults()
log.Fatalf("invalid parameters, region required")
}
if len(objectName) == 0 {
flag.PrintDefaults()
log.Fatalf("invalid parameters, object name required")
}
cfg := oss.LoadDefaultConfig().
WithCredentialsProvider(credentials.NewEnvironmentVariableCredentialsProvider()).
WithRegion(region)
client := oss.NewClient(cfg)
f, err := client.OpenFile(context.TODO(), bucketName, objectName)
defer f.Close()
if err != nil {
log.Fatalf("failed to open file %v", err)
}
stat, err := f.Stat()
if err != nil {
log.Fatalf("failed to stat file %v", err)
}
var contentBuilder strings.Builder
buf := make([]byte, stat.Size())
for {
n, err := f.Read(buf)
if err != nil {
if err.Error() == "EOF" {
break
}
log.Fatalf("failed to read object: %v", err)
}
if n == 0 {
break
}
contentBuilder.Write(buf[:n])
}
log.Printf("body content:%#v\n", contentBuilder.String())
}