# Using pip
pip install visent-sdk

# Using poetry
poetry add visent-sdk

# Using conda
conda install -c conda-forge visent-sdk

from visent import VisentClient

# Initialize client
client = VisentClient(api_key='your_api_key_here')

# Or use environment variable
import os
client = VisentClient(api_key=os.getenv('VISENT_API_KEY'))

# Get current GPU metrics
metrics = client.telemetry.get_metrics(
    node='gpu-worker-1',
    gpu=0
)

print(f"GPU Utilization: {metrics.utilization}%")
print(f"Memory Usage: {metrics.memory_used / 1e9:.1f} GB")
print(f"Temperature: {metrics.temperature}°C")

# Get historical metrics
historical = client.telemetry.get_historical_metrics(
    node='gpu-worker-1',
    start_time='2024-01-01T00:00:00Z',
    end_time='2024-01-02T00:00:00Z'
)

# Create alert rule
alert = client.telemetry.create_alert(
    name='High GPU Temperature',
    condition='gpu_temperature > 85',
    duration='5m',
    severity='critical'
)

# Get current pricing
pricing = client.atlas.get_current_pricing(
    gpu='h100',
    provider='aws',
    region='us-east-1'
)

print(f"Price: ${pricing.price_per_hour}/hour")
print(f"Availability: {pricing.availability}")

# Get market trends
trends = client.atlas.get_market_trends(
    gpu='h100',
    period='30d'
)

# Cost optimization
recommendations = client.atlas.get_optimization_recommendations(
    workload='ml-training',
    budget=10000,
    requirements={
        'min_gpus': 8,
        'memory_per_gpu': '80GB'
    }
)

# Start a benchmark
benchmark = client.forge.start_benchmark(
    type='ml-training',
    gpu='h100',
    config={
        'model': 'resnet50',
        'batch_size': 32,
        'iterations': 100
    }
)

print(f"Benchmark started: {benchmark.job_id}")

# Wait for completion
result = client.forge.wait_for_completion(
    benchmark.job_id,
    timeout=3600  # 1 hour timeout
)

print(f"Throughput: {result.metrics.throughput} ops/sec")
print(f"Latency: {result.metrics.latency} ms")

# Get benchmark report
report = client.forge.get_report(
    benchmark.job_id,
    format='json'
)

import asyncio
from visent import AsyncVisentClient

async def main():
    client = AsyncVisentClient(api_key='your_api_key_here')
    
    # Async API calls
    metrics = await client.telemetry.get_metrics(node='gpu-worker-1')
    pricing = await client.atlas.get_current_pricing(gpu='h100')
    
    await client.close()

# Run async code
asyncio.run(main())

from visent.exceptions import VisentAPIError, RateLimitError

try:
    metrics = client.telemetry.get_metrics(node='invalid-node')
except RateLimitError as e:
    print(f"Rate limited: {e.retry_after} seconds")
except VisentAPIError as e:
    print(f"API error: {e.message}")