Function main

examples/s3/s3-outposts-put-get.go:55–117

()

)

func main() {
	endpoint := os.Getenv("S3_OUTPOSTS_ENDPOINT")
	bucket := os.Getenv("S3_OUTPOSTS_BUCKET")
	region := os.Getenv("S3_OUTPOSTS_REGION")
	if region == "" {
		region = os.Getenv("AWS_REGION")
	}
	profile := os.Getenv("S3_OUTPOSTS_PROFILE")

	if endpoint == "" || bucket == "" || region == "" {
		log.Fatalf("Missing required env: set S3_OUTPOSTS_ENDPOINT, S3_OUTPOSTS_BUCKET, and S3_OUTPOSTS_REGION (or AWS_REGION)")
	}

	var creds *credentials.Credentials
	if profile != "" {
		creds = credentials.NewFileAWSCredentials("", profile)
	} else {
		accessKey := os.Getenv("AWS_ACCESS_KEY_ID")
		secretKey := os.Getenv("AWS_SECRET_ACCESS_KEY")
		if accessKey == "" || secretKey == "" {
			log.Fatalf("Set S3_OUTPOSTS_PROFILE or both AWS_ACCESS_KEY_ID and AWS_SECRET_ACCESS_KEY")
		}
		creds = credentials.NewStaticV4(accessKey, secretKey, "")
	}

	client, err := minio.New(endpoint, &minio.Options{
		Creds:  creds,
		Secure: true,
		Region: region,
	})
	if err != nil {
		log.Fatalf("New client: %v", err)
	}

	objectKey := "outposts-test/hello-minio-go.txt"
	objectBody := "Hello from minio-go S3 on Outposts\n"

	ctx := context.Background()

	fmt.Println("PutObject...")
	_, err = client.PutObject(ctx, bucket, objectKey, strings.NewReader(objectBody), int64(len(objectBody)), minio.PutObjectOptions{
		ContentType: "text/plain",
	})
	if err != nil {
		log.Fatalf("PutObject: %v", err)
	}
	fmt.Println("PutObject OK")

	fmt.Println("GetObject...")
	obj, err := client.GetObject(ctx, bucket, objectKey, minio.GetObjectOptions{})
	if err != nil {
		log.Fatalf("GetObject: %v", err)
	}
	defer obj.Close()

	data, err := io.ReadAll(obj)
	if err != nil {
		log.Fatalf("Read body: %v", err)