add example in python

Author: HarshCasper

examples/python/.gitattributes

@@ -0,0 +1 @@
+/sdk/** linguist-generated

examples/python/.gitignore

@@ -0,0 +1,3 @@
+/sdk
+/.venv
+/**/__pycache__

examples/python/dagger.json

@@ -0,0 +1,13 @@
+{
+  "name": "example",
+  "engineVersion": "v0.18.2",
+  "sdk": {
+    "source": "python"
+  },
+  "dependencies": [
+    {
+      "name": "localstack-dagger-module",
+      "source": "../.."
+    }
+  ]
+}

examples/python/pyproject.toml

@@ -0,0 +1,12 @@
+[project]
+name = "example"
+version = "0.1.0"
+requires-python = ">=3.12"
+dependencies = ["dagger-io", "boto3"]
+
+[tool.uv.sources]
+dagger-io = { path = "sdk", editable = true }
+
+[build-system]
+requires = ["hatchling==1.25.0"]
+build-backend = "hatchling.build"

examples/python/src/example/__init__.py

@@ -0,0 +1,16 @@
+"""A generated module for Example functions
+
+This module has been generated via dagger init and serves as a reference to
+basic module structure as you get started with Dagger.
+
+Two functions have been pre-created. You can modify, delete, or add to them,
+as needed. They demonstrate usage of arguments and return types using simple
+echo and grep commands. The functions can be called from the dagger CLI or
+from one of the SDKs.
+
+The first line in this comment block is a short description line and the
+rest is a long description with more detail on the module's purpose or usage,
+if appropriate. All modules should have a short description.
+"""
+
+from .main import Example as Example

examples/python/src/example/main.py

@@ -0,0 +1,155 @@
+import dagger
+from dagger import dag, function, object_type
+import boto3
+import time
+
+@object_type
+class Example:
+    @function
+    async def localstack_dagger_module__quickstart(self) -> str:
+        """Example showing how to start LocalStack Community edition."""
+        service = dag.localstack_dagger_module().start()
+        
+        await service.start()
+        endpoint = await service.endpoint()
+        print(f"LocalStack is running at {endpoint}")
+
+        # Create a test S3 bucket
+        s3 = boto3.client(
+            's3',
+            endpoint_url=f"http://{endpoint}",
+            aws_access_key_id='test',
+            aws_secret_access_key='test',
+            region_name='us-east-1'
+        )
+        s3.create_bucket(Bucket='test-bucket')
+
+        print("S3 bucket created")
+
+        # Create a test object
+        s3.put_object(
+            Bucket='test-bucket',
+            Key='test-object',
+            Body='Hello, LocalStack!'
+        )
+        print("S3 object created")
+
+        # Verify the object was created
+        response = s3.get_object(Bucket='test-bucket', Key='test-object')
+        content = response['Body'].read().decode('utf-8')
+        print(f"S3 object content: {content}")
+
+    @function
+    async def localstack_dagger_module__pro(self, auth_token: dagger.Secret) -> str:
+        """Example showing how to start LocalStack Pro with custom configuration."""
+        # Start LocalStack Pro using the module
+        service = dag.localstack_dagger_module().start(
+            auth_token=auth_token,
+            configuration="DEBUG=1,SERVICES=ecr"
+        )
+
+        await service.start()
+        endpoint = await service.endpoint()
+        print(f"LocalStack Pro is running at {endpoint}")
+
+        # Create a test ECR repository
+        ecr = boto3.client(
+            'ecr',
+            endpoint_url=f"http://{endpoint}",
+            aws_access_key_id='test',
+            aws_secret_access_key='test',
+            region_name='us-east-1'
+        )
+
+        repository_name = "test-ecr-repo"
+        ecr.create_repository(repositoryName=repository_name)
+        print(f"ECR repository '{repository_name}' created")
+
+    @function
+    async def localstack_dagger_module__state(self, auth_token: dagger.Secret) -> str:
+        """Example showing how to manage LocalStack state using Cloud Pods."""
+        service = dag.localstack_dagger_module().start(auth_token=auth_token)
+        await service.start()
+        endpoint = await service.endpoint()
+
+        try:
+            # Create a test bucket
+            s3 = boto3.client(
+                's3',
+                endpoint_url=f"http://{endpoint}",
+                aws_access_key_id='test',
+                aws_secret_access_key='test',
+                region_name='us-east-1'
+            )
+            s3.create_bucket(Bucket='test-bucket')
+
+            # Save state to Cloud Pod
+            await dag.localstack_dagger_module().state(
+                auth_token=auth_token,
+                save="test-dagger-example-pod",
+                endpoint=f"http://{endpoint}"
+            )
+
+            # Reset state
+            await dag.localstack_dagger_module().state(
+                reset=True,
+                endpoint=f"http://{endpoint}"
+            )
+
+            # Load state back
+            await dag.localstack_dagger_module().state(
+                auth_token=auth_token,
+                load="test-dagger-example-pod",
+                endpoint=f"http://{endpoint}"
+            )
+
+            return "Success: State operations completed"
+        except Exception as e:
+            return f"Error: {str(e)}"
+
+    @function
+    async def localstack_dagger_module_ephemeral(self, auth_token: dagger.Secret) -> str:
+        """Example showing how to manage LocalStack Ephemeral Instances."""
+        try:
+            # Create a new ephemeral instance
+            await dag.localstack_dagger_module().ephemeral(
+                auth_token=auth_token,
+                operation="create",
+                name="test-dagger-example-instance",
+                lifetime=60,
+            )
+            
+            # Wait for instance to be ready
+            time.sleep(15)
+
+            print("Instance created")
+            
+            # List instances
+            list_response = await dag.localstack_dagger_module().ephemeral(
+                auth_token=auth_token,
+                operation="list"
+            )
+
+            print(f"Ephemeral instances: {list_response}")
+            
+            # Get instance logs
+            instance_logs = await dag.localstack_dagger_module().ephemeral(
+                auth_token=auth_token,
+                operation="logs",
+                name="test-dagger-example-instance"
+            )
+
+            print(f"Instance logs: {instance_logs}")
+            
+            # Delete instance
+            await dag.localstack_dagger_module().ephemeral(
+                auth_token=auth_token,
+                operation="delete",
+                name="test-dagger-example-instance"
+            )
+
+            print("Instance deleted")
+            
+            return "Success: Ephemeral instance operations completed"
+        except Exception as e:
+            return f"Error: {str(e)}"