Usable Capacity = Raw Capacity x (data_shards / (data_shards + parity_shards))

# Configure credentials (use KDSS access key / secret key)
aws configure
# AWS Access Key ID: your-access-key
# AWS Secret Access Key: your-secret-key
# Default region name: us-east-1
# Default output format: json

# Set alias for convenience
alias s3='aws --endpoint-url http://master-host:9000 s3'
alias s3api='aws --endpoint-url http://master-host:9000 s3api'

# Bucket operations
s3 mb s3://my-bucket                          # Create bucket
s3 ls                                         # List buckets
s3 ls s3://my-bucket/                         # List objects
s3 rb s3://my-bucket --force                  # Delete bucket

# Upload / Download
s3 cp local-file.dat s3://my-bucket/          # Upload file
s3 cp s3://my-bucket/file.dat ./              # Download file
s3 cp ./data/ s3://my-bucket/data/ --recursive  # Upload directory
s3 sync ./backup/ s3://my-bucket/backup/      # Sync directory

# Delete
s3 rm s3://my-bucket/file.dat                 # Delete object
s3 rm s3://my-bucket/ --recursive             # Delete all objects

[default]
access_key = your-access-key
secret_key = your-secret-key
host_base = master-host:9000
host_bucket = master-host:9000/%(bucket)
use_https = False
signature_v2 = False

# Bucket operations
s3cmd mb s3://my-bucket
s3cmd ls

# Upload / Download
s3cmd put file.dat s3://my-bucket/
s3cmd get s3://my-bucket/file.dat ./
s3cmd sync ./data/ s3://my-bucket/data/

# File info
s3cmd info s3://my-bucket/file.dat

import boto3

# Create S3 client pointing to KDSS
s3 = boto3.client(
    "s3",
    endpoint_url="http://master-host:9000",
    aws_access_key_id="your-access-key",
    aws_secret_access_key="your-secret-key",
    region_name="us-east-1",
)

# Create bucket
s3.create_bucket(Bucket="my-bucket")

# Upload file
s3.upload_file("local-file.dat", "my-bucket", "path/to/file.dat")

# Download file
s3.download_file("my-bucket", "path/to/file.dat", "downloaded.dat")

# List objects
resp = s3.list_objects_v2(Bucket="my-bucket", Prefix="path/")
for obj in resp.get("Contents", []):
    print(obj["Key"], obj["Size"])

# Generate presigned URL (valid for 1 hour)
url = s3.generate_presigned_url(
    "get_object",
    Params={"Bucket": "my-bucket", "Key": "path/to/file.dat"},
    ExpiresIn=3600,
)
print(url)

# Delete object
s3.delete_object(Bucket="my-bucket", Key="path/to/file.dat")

package main

import (
    "context"
    "fmt"
    "os"

    "github.com/aws/aws-sdk-go-v2/aws"
    "github.com/aws/aws-sdk-go-v2/config"
    "github.com/aws/aws-sdk-go-v2/credentials"
    "github.com/aws/aws-sdk-go-v2/service/s3"
)

func main() {
    // Create S3 client pointing to KDSS
    cfg, _ := config.LoadDefaultConfig(context.TODO(),
        config.WithRegion("us-east-1"),
        config.WithCredentialsProvider(
            credentials.NewStaticCredentialsProvider("your-access-key", "your-secret-key", ""),
        ),
    )
    client := s3.NewFromConfig(cfg, func(o *s3.Options) {
        o.BaseEndpoint = aws.String("http://master-host:9000")
        o.UsePathStyle = true
    })

    // Upload file
    file, _ := os.Open("local-file.dat")
    defer file.Close()
    client.PutObject(context.TODO(), &s3.PutObjectInput{
        Bucket: aws.String("my-bucket"),
        Key:    aws.String("path/to/file.dat"),
        Body:   file,
    })

    // List objects
    resp, _ := client.ListObjectsV2(context.TODO(), &s3.ListObjectsV2Input{
        Bucket: aws.String("my-bucket"),
    })
    for _, obj := range resp.Contents {
        fmt.Printf("%s  %d bytes\n", *obj.Key, *obj.Size)
    }
}