Retrieve File Content

# Backup all user data files
files = client.files.list(purpose="user_data")

for file in files.data:
    content = client.files.content(file.id)
    with open(f"backup/{file.filename}", "wb") as f:
        f.write(content)

# Analyze document content
content = client.files.content("file-abc123")
text = content.decode('utf-8')

# Extract insights
word_count = len(text.split())
char_count = len(text)
print(f"Document: {word_count} words, {char_count} characters")

import requests

def stream_download(file_id, output_path):
    """Stream download large files"""
    url = f"https://api.gravixlayer.com/v1/files/{file_id}/content"
    headers = {"Authorization": f"Bearer {api_key}"}
    
    with requests.get(url, headers=headers, stream=True) as r:
        r.raise_for_status()
        
        total_size = int(r.headers.get('content-length', 0))
        downloaded = 0
        
        with open(output_path, 'wb') as f:
            for chunk in r.iter_content(chunk_size=8192):
                f.write(chunk)
                downloaded += len(chunk)
                
                # Show progress
                if total_size > 0:
                    progress = (downloaded / total_size) * 100
                    print(f"\rDownloading: {progress:.1f}%", end="")
    
    print(f"\nDownload complete: {output_path}")

# Usage for large files
stream_download("file-abc123", "large_dataset.zip")

import hashlib

def download_with_validation(file_id, expected_hash=None):
    """Download file and validate its content"""
    content = client.files.content(file_id)
    
    # Calculate hash of downloaded content
    file_hash = hashlib.sha256(content).hexdigest()
    
    # Validate if expected hash provided
    if expected_hash and file_hash != expected_hash:
        raise ValueError(f"File integrity check failed. Expected: {expected_hash}, Got: {file_hash}")
    
    # Additional content validation
    file_size = len(content)
    
    if file_size == 0:
        raise ValueError("Downloaded file is empty")
    
    print(f"✅ File downloaded and validated")
    print(f"   Size: {file_size:,} bytes")
    print(f"   SHA256: {file_hash}")
    
    return content

# Usage
try:
    content = download_with_validation("file-abc123")
    with open("validated_file.jsonl", "wb") as f:
        f.write(content)
except ValueError as e:
    print(f"❌ Validation error: {e}")

import concurrent.futures
import os

def download_single_file(file_info):
    """Download a single file"""
    file_id, filename = file_info
    
    try:
        content = client.files.content(file_id)
        
        # Ensure directory exists
        os.makedirs("downloads", exist_ok=True)
        
        # Save file
        filepath = os.path.join("downloads", filename)
        with open(filepath, "wb") as f:
            f.write(content)
        
        return f"✅ Downloaded: {filename}"
        
    except Exception as e:
        return f"❌ Failed: {filename} - {e}"

def download_files_batch(file_list):
    """Download multiple files concurrently"""
    # file_list: [(file_id, filename), ...]
    
    with concurrent.futures.ThreadPoolExecutor(max_workers=5) as executor:
        results = list(executor.map(download_single_file, file_list))
    
    for result in results:
        print(result)

# Usage
files_to_download = [
    ("file-abc123", "dataset1.jsonl"),
    ("file-def456", "dataset2.jsonl"),
    ("file-ghi789", "images.zip")
]

download_files_batch(files_to_download)