Este tópico descreve como usar o download por intervalo para baixar um intervalo específico de dados de um objeto de maneira eficiente.
Observações
Neste tópico, é utilizado o endpoint público da região China (Hangzhou). Se você quiser acessar o OSS a partir de outros services da Alibaba Cloud na mesma região do OSS, use um endpoint interno. Para mais informações sobre as regiões e endpoints do OSS, consulte Regions and endpoints.
Neste tópico, as credenciais de acesso são obtidas a partir de variáveis de ambiente. Para mais informações sobre como configurar as credenciais de acesso, consulte Configure access credentials.
Este tópico demonstra a criação de uma instância OSSClient com um endpoint do OSS. Para configurações alternativas, como o uso de um domínio personalizado ou autenticação com credenciais do Security Token Service (STS), consulte Configure a client (Go SDK V1).
Para realizar o download por intervalo, você deve ter a permissão
oss:GetObject. Para mais informações, consulte Grant a custom policy.
Código de exemplo
O código de exemplo a seguir é usado para baixar um intervalo específico de dados de um objeto.
package main
import (
"io"
"log"
"strings"
"github.com/aliyun/aliyun-oss-go-sdk/oss"
)
func main() {
// Obtain access credentials from environment variables. Before you run the sample code, make sure that the OSS_ACCESS_KEY_ID and OSS_ACCESS_KEY_SECRET environment variables are configured.
provider, err := oss.NewEnvironmentVariableCredentialsProvider()
if err != nil {
log.Fatalf("Error: %v", err)
}
// Create an OSSClient instance.
// Specify the endpoint of the region in which the bucket is located. For example, if the bucket is located in the China (Hangzhou) region, set the endpoint to https://oss-cn-hangzhou.aliyuncs.com. Specify your actual endpoint.
// Specify the region in which the bucket is located. For example, if the bucket is located in the China (Hangzhou) region, set the region to cn-hangzhou. Specify the actual region.
clientOptions := []oss.ClientOption{oss.SetCredentialsProvider(&provider)}
clientOptions = append(clientOptions, oss.Region("yourRegion"))
// Specify the version of the signature algorithm.
clientOptions = append(clientOptions, oss.AuthVersion(oss.AuthV4))
client, err := oss.New("yourEndpoint", "", "", clientOptions...)
if err != nil {
log.Fatalf("Error: %v", err)
}
// Specify the name of the bucket.
bucketName := "yourBucketName"
bucket, err := client.Bucket(bucketName)
if err != nil {
log.Fatalf("Error: %v", err)
}
// Upload 1,000 bytes.
strContent := ""
for i := 0; i < 100; i++ {
strContent += "abcdefghij"
}
log.Printf("content len: %d\n", len(strContent))
// Upload a string.
objectName := "yourObjectName"
err = bucket.PutObject(objectName, strings.NewReader(strContent))
if err != nil {
log.Fatalf("Error: %v", err)
}
// Query the data that is within the range from byte 15 to byte 35, which includes a total of 21 bytes.
// If the specified value range is invalid, the entire object is downloaded. For example, if the specified range includes a negative number or the specified value is greater than the object size, all content of the object is downloaded.
body, err := bucket.GetObject(objectName, oss.Range(15, 35))
if err != nil {
log.Fatalf("Error: %v", err)
}
defer body.Close()
// Read the data and load it into the memory.
data, err := io.ReadAll(body)
if err != nil {
log.Fatalf("Error: %v", err)
}
log.Printf("data: %s", string(data))
}