import requests
import base64
import pandas as pd
import json

# Credentials you'll receive after subscription
CLIENT_ID =  
CLIENT_SECRET =  
X_API_KEY = 
ACCESS_TOKEN_URL =  
ENDPOINT_URL =  

# Generate Basic Auth token for access token request
message = f'{CLIENT_ID}:{CLIENT_SECRET}'.encode('utf-8')
secret_hash = base64.b64encode(message).decode('utf-8')

# Prepare request payload and headers to obtain access token
post_payload = {'grant_type': 'client_credentials'}
headers = {
    'Content-Type': 'application/x-www-form-urlencoded',
    'Authorization': f'Basic {secret_hash}'
}

# Request access token (valid for 1 hour)
res = requests.post(ACCESS_TOKEN_URL, data=post_payload, headers=headers)
res.raise_for_status()  # Raise an error for bad responses
access_token = res.json().get('access_token')

if not access_token:
    raise ValueError("Failed to retrieve access token.")

# Prepare API request headers with the retrieved access token
api_headers = {
    'x-api-key': X_API_KEY,
    'Authorization': f'Bearer {access_token}'
}

# Define query parameters for API request
query_payload = {
    'activityID': 'rice',
    'country': 'Portugal',
    'impact_category': 'Land_use_Urban',
    'activity_classification_system': 'GLORIA',
    'size': 1  # Limit number of records returned
}

# Make API request
api_res = requests.get(ENDPOINT_URL, headers=api_headers, params=query_payload)
api_res.raise_for_status()  # Raise an error for bad responses

# Parse JSON response
data = api_res.json()

# Display retrieved data
print(f"{data.get('num_records', 0)} records found for:")
print(json.dumps(query_payload, indent=3))
print('From:', ENDPOINT_URL)

# Convert records to a Pandas DataFrame for easier analysis
records_df = pd.DataFrame.from_records(data.get('records', []))
print(records_df)