Redispatch Export REST API

const API_TOKEN = 'YOUR_API_TOKEN';
const BASE_URL = 'https://api.cernion.de';

// Job starten
async function startRedispatchExport() {
  const response = await fetch(`${BASE_URL}/api/grid-operations/redispatch-export`, {
    method: 'POST',
    headers: {
      'Authorization': `Bearer ${API_TOKEN}`,
      'Content-Type': 'application/json'
    },
    body: JSON.stringify({
      gridOperator: 'Stadtwerke München',
      minCapacity: 100,
      types: ['solar', 'wind']
    })
  });
  
  const data = await response.json();
  console.log('Job ID:', data.jobId);
  return data.jobId;
}

// Job Status polling
async function pollJobStatus(jobId) {
  const response = await fetch(`${BASE_URL}/api/system/job-status/${jobId}`, {
    headers: {
      'Authorization': `Bearer ${API_TOKEN}`
    }
  });
  
  const data = await response.json();
  
  if (data.status === 'succeeded') {
    // Ergebnis abrufen
    const resultResponse = await fetch(`${BASE_URL}/api/system/job-result/${jobId}`, {
      headers: { 'Authorization': `Bearer ${API_TOKEN}` }
    });
    return await resultResponse.json();
  } else if (data.status === 'failed') {
    throw new Error('Job failed: ' + data.error);
  } else {
    // Noch nicht fertig, nochmal prüfen
    await new Promise(resolve => setTimeout(resolve, 2000));
    return pollJobStatus(jobId);
  }
}

// Alles zusammen
(async () => {
  const jobId = await startRedispatchExport();
  const result = await pollJobStatus(jobId);
  console.log('Ergebnis:', result);
})();

import requests
import time

API_TOKEN = 'YOUR_API_TOKEN'
BASE_URL = 'https://api.cernion.de'

def start_redispatch_export():
    """Job starten"""
    response = requests.post(
        f'{BASE_URL}/api/grid-operations/redispatch-export',
        headers={
            'Authorization': f'Bearer {API_TOKEN}',
            'Content-Type': 'application/json'
        },
        json={
            'gridOperator': 'Stadtwerke München',
            'minCapacity': 100,
            'types': ['solar', 'wind']
        }
    )
    data = response.json()
    print(f'Job ID: {data["jobId"]}')
    return data['jobId']

def poll_job_status(job_id, max_attempts=30):
    """Job Status polling mit Timeout"""
    for attempt in range(max_attempts):
        response = requests.get(
            f'{BASE_URL}/api/system/job-status/{job_id}',
            headers={'Authorization': f'Bearer {API_TOKEN}'}
        )
        data = response.json()
        
        if data['status'] == 'succeeded':
            # Ergebnis abrufen
            result_response = requests.get(
                f'{BASE_URL}/api/system/job-result/{job_id}',
                headers={'Authorization': f'Bearer {API_TOKEN}'}
            )
            return result_response.json()
        elif data['status'] == 'failed':
            raise Exception(f'Job failed: {data.get("error")}')
        
        print(f'Status: {data["status"]}, Progress: {data.get("progress", 0)}%')
        time.sleep(2)
    
    raise TimeoutError('Job timeout after 60 seconds')

# Alles zusammen
if __name__ == '__main__':
    job_id = start_redispatch_export()
    result = poll_job_status(job_id)
    
    print(f'\\nErgebnis:')
    print(f'Netzbetreiber: {result["gridOperator"]}')
    print(f'Anlagen gefunden: {result["totalCount"]}')
    print(f'Gesamtleistung: {result["totalCapacityMW"]} MW')