💰 Cloud Cost Optimization in DevOps

# Cost-aware EC2 auditor: estimates costs and flags idle/oversized instances (dry-run)
import boto3, datetime
from botocore.exceptions import NoCredentialsError

# Simple hourly price map (USD). Extend as needed.
PRICE_PER_HOUR = {
  't3.micro': 0.0104, 't3.small': 0.0208, 't3.medium': 0.0416,
  'm5.large': 0.096, 'm5.xlarge': 0.192
}

def get_avg_cpu(cw_client, instance_id, period_hours=168):
  end = datetime.datetime.utcnow()
  start = end - datetime.timedelta(hours=period_hours)
  try:
    resp = cw_client.get_metric_statistics(
      Namespace='AWS/EC2',
      MetricName='CPUUtilization',
      Dimensions=[{'Name':'InstanceId','Value':instance_id}],
      StartTime=start, EndTime=end, Period=86400, Statistics=['Average']
    )
    datapoints = resp.get('Datapoints', [])
    if not datapoints:
      return None
    return sum(p['Average'] for p in datapoints) / len(datapoints)
  except Exception:
    return None

def estimate_hourly_cost(instance_type):
  return PRICE_PER_HOUR.get(instance_type, 0.05)  # fallback estimate

def analyze_instances(region='us-east-1', idle_cpu_threshold=10.0, days=7, do_action=False):
  try:
    ec2 = boto3.client('ec2', region_name=region)
    cw = boto3.client('cloudwatch', region_name=region)
    resp = ec2.describe_instances()
    for r in resp['Reservations']:
      for i in r['Instances']:
        iid = i['InstanceId']
        itype = i.get('InstanceType', 'unknown')
        tags = {t['Key']: t['Value'] for t in i.get('Tags', [])}
        avg_cpu = get_avg_cpu(cw, iid, period_hours=24*days)
        hourly = estimate_hourly_cost(itype)
        monthly_cost = hourly * 24 * 30
        status = i.get('State', {}).get('Name')
        print(f"{iid} ({itype}) status={status} owner={tags.get('Owner','-')} env={tags.get('Environment','-')}")
        print(f"  avg_cpu={avg_cpu if avg_cpu is not None else 'N/A'}%  est_hourly=${hourly:.4f}  est_monthly=${monthly_cost:.2f}")
        if avg_cpu is not None and avg_cpu < idle_cpu_threshold and status == 'running':
          print("  -> Recommendation: Instance appears idle. Consider stopping, rightsizing, or using spot/reserved pricing.")
          if do_action:
            print("     (dry-run) Would stop instance here.")
        print("")
  except NoCredentialsError:
    print("AWS credentials not available.")
  except Exception as e:
    print("Error:", e)

if __name__ == '__main__':
  # set do_action=True to perform cloud actions (not recommended in examples)
  analyze_instances(region='us-east-1', idle_cpu_threshold=10.0, days=7, do_action=False)