aws-requests-auth

import requests import os from aws_requests_auth.aws_auth import AWSRequestsAuth aws_access_key = os.environ.get('AWS_ACCESS_KEY_ID', 'YOUR_ACCESS_KEY') aws_secret_key = os.environ.get('AWS_SECRET_ACCESS_KEY', 'YOUR_SECRET_KEY') aws_region = os.environ.get('AWS_DEFAULT_REGION', 'us-east-1') aws_service = 'es' # Example service, e.g., 'es' for Elasticsearch, 's3', 'execute-api' aws_host = 'your-aws-endpoint.amazonaws.com' # For STS temporary credentials, include aws_token aws_token = os.environ.get('AWS_SESSION_TOKEN') auth = AWSRequestsAuth( aws_access_key=aws_access_key, aws_secret_access_key=aws_secret_key, aws_host=aws_host, aws_region=aws_region, aws_service=aws_service, aws_token=aws_token # Pass if using STS temporary credentials ) try: # Replace with your actual endpoint response = requests.get(f'https://{aws_host}/_cat/health', auth=auth, timeout=10) response.raise_for_status() # Raise an exception for HTTP errors print("Successfully authenticated and received response:") print(response.text) except requests.exceptions.RequestException as e: print(f"Request failed: {e}") if hasattr(e, 'response') and e.response is not None: print(f"Response Status Code: {e.response.status_code}") print(f"Response Body: {e.response.text}") print("Please ensure your AWS credentials, host, region, and service are correct.")