From 6f7be0ac96f19f381f981dd9ebd18921c776a57c Mon Sep 17 00:00:00 2001
From: KenF <kenf@dev.internal>
Date: Thu, 22 Jan 2026 10:05:14 +0800
Subject: [PATCH] feat: porting shell scripts to python

---
 aws-elasticache-inventory.sh | 16 ----------------
 aws-elasticache.py           | 32 ++++++++++++++++++++++++++++++++
 aws-subnet-inventory.sh      | 16 ----------------
 aws-subnets.py               | 35 +++++++++++++++++++++++++++++++++++
 4 files changed, 67 insertions(+), 32 deletions(-)
 delete mode 100755 aws-elasticache-inventory.sh
 create mode 100755 aws-elasticache.py
 delete mode 100755 aws-subnet-inventory.sh
 create mode 100755 aws-subnets.py

diff --git a/aws-elasticache-inventory.sh b/aws-elasticache-inventory.sh
deleted file mode 100755
index 9aa82d2..0000000
--- a/aws-elasticache-inventory.sh
+++ /dev/null
@@ -1,16 +0,0 @@
-#!/bin/bash
-
-function listRes() {
-	aws elasticache --region $1 describe-cache-clusters | jq -cr '.CacheClusters[] | [.CacheClusterId, .CacheNodeType, .Engine, .PreferredAvailabilityZone] | @csv' | tr -d \"
-}
-
-export -f listRes
-
-# Generate inventory of ec2 in all regions
-
-echo "ClusterId,NodeType,Engine,AZ"
-aws --region=us-east-1 ec2 describe-regions --query Regions[].RegionName --output text | sed -e 's/\t/\n/g' | while read r; do
-	sem -j6 listRes $r
-done
-
-sem --wait
diff --git a/aws-elasticache.py b/aws-elasticache.py
new file mode 100755
index 0000000..a2e9b1c
--- /dev/null
+++ b/aws-elasticache.py
@@ -0,0 +1,32 @@
+#!/usr/bin/env python3
+r"""
+Documentation
+
+License: This program is released under the MIT License
+"""
+
+# Imports
+import boto3
+import concurrent.futures
+
+def getRegions(all_regions=False):
+    ec2 = boto3.client('ec2')
+    response = ec2.describe_regions(AllRegions=all_regions)
+    return [region['RegionName'] for region in response['Regions']]
+
+def printResources(region_name: str):
+    client = boto3.client('elasticache', region_name=region_name)
+    response = client.describe_cache_clusters()
+    for i in response['CacheClusters']:
+        print(f"{i['CacheClusterId']}, {i['CacheNodeType']}, {i['Engine']}, {i['EngineVersion']}, {i['NumCacheNodes']}, {i['PreferredAvailabilityZone']}")
+
+# Main function
+def main() -> None:
+    print("CacheClusterId, CacheNodeType, Engine, EngineVersion, NumCacheNodes, AZ")
+    with concurrent.futures.ProcessPoolExecutor(max_workers=6) as executor:
+        futures = [executor.submit(printResources, region_name=r) for r in getRegions()]
+        results = [future.result() for future in concurrent.futures.wait(futures).done]
+
+# Call main function
+if __name__ == '__main__':
+    main()
diff --git a/aws-subnet-inventory.sh b/aws-subnet-inventory.sh
deleted file mode 100755
index e4076fb..0000000
--- a/aws-subnet-inventory.sh
+++ /dev/null
@@ -1,16 +0,0 @@
-#!/bin/bash
-
-function listRes() {
-	aws --region $1 ec2 describe-subnets | jq -cr '.Subnets[] | [.SubnetId, .VpcId, .CidrBlock, .AvailabilityZone] | @csv' | tr -d \"
-}
-
-export -f listRes
-
-# Generate inventory in all regions
-
-echo "SubnetId,VpcId,CidrBlock,AZ"
-aws --region=us-east-1 ec2 describe-regions --query Regions[].RegionName --output text | sed -e 's/\t/\n/g' | while read r; do
-	sem -j6 listRes $r
-done
-
-sem --wait
diff --git a/aws-subnets.py b/aws-subnets.py
new file mode 100755
index 0000000..706d250
--- /dev/null
+++ b/aws-subnets.py
@@ -0,0 +1,35 @@
+#!/usr/bin/env python3
+r"""
+Documentation
+
+License: This program is released under the MIT License
+"""
+
+# Imports
+import boto3
+import concurrent.futures
+
+def getRegions(all_regions=False):
+    ec2 = boto3.client('ec2')
+    response = ec2.describe_regions(AllRegions=all_regions)
+    return [region['RegionName'] for region in response['Regions']]
+
+def printResources(region_name: str):
+    client = boto3.client('ec2', region_name=region_name)
+    response = client.describe_subnets()
+    for i in response['Subnets']:
+        default_vpc_check = client.describe_vpcs(VpcIds=[i['VpcId']])
+        for v in default_vpc_check['Vpcs']:
+            if not v['IsDefault']:
+                print(f"{i['SubnetId']}, {i['VpcId']}, {i['CidrBlock']}, {i['AvailabilityZone']}")
+
+# Main function
+def main() -> None:
+    print("SubnetId, VpcId, CidrBlock, AvailabilityZone")
+    with concurrent.futures.ProcessPoolExecutor(max_workers=6) as executor:
+        futures = [executor.submit(printResources, region_name=r) for r in getRegions()]
+        results = [future.result() for future in concurrent.futures.wait(futures).done]
+
+# Call main function
+if __name__ == '__main__':
+    main()