s5cmd_s3_sync_subprocess_wrapper_with_error_handling.py

1import subprocess
2import sys
3
4def s5cmd_quickstart():
5    # Define the command (e.g., sync a local folder to an S3 bucket)
6    # This assumes s5cmd is installed and available in your PATH
7    source = "./local-folder"
8    destination = "s3://my-bucket/backup/"
9    
10    command = ["s5cmd", "sync", source, destination]
11
12    try:
13        print(f"Starting s5cmd sync: {source} -> {destination}")
14        
15        # Execute the command and capture output
16        result = subprocess.run(
17            command, 
18            check=True, 
19            capture_output=True, 
20            text=True
21        )
22        
23        print("Sync completed successfully.")
24        print(result.stdout)
25
26    except subprocess.CalledProcessError as e:
27        print(f"Error occurred: {e.stderr}", file=sys.stderr)
28    except FileNotFoundError:
29        print("Error: s5cmd binary not found. Please install it from https://github.com/peak/s5cmd")
30
31if __name__ == "__main__":
32    s5cmd_quickstart()