Update gov2 transfer manager examples

.doc_gen/metadata/sesv2_metadata.yaml

@@ -39,7 +39,7 @@ sesv2_CreateContactList:
     Python:
       versions:
         - sdk_version: 3
-          github: python/example_code/sesv2
+          github: python/example_code/sesv2/newsletter_scenario
           excerpts:
             - description:
               genai: most
@@ -89,7 +89,7 @@ sesv2_CreateContact:
     Python:
       versions:
         - sdk_version: 3
-          github: python/example_code/sesv2
+          github: python/example_code/sesv2/newsletter_scenario
           excerpts:
             - description:
               genai: most
@@ -101,6 +101,15 @@ sesv2_CreateContact:
     sesv2: {CreateContact}
 sesv2_GetEmailIdentity:
   languages:
+    Python:
+      versions:
+        - sdk_version: 3
+          github: python/example_code/sesv2/attachments_scenario
+          excerpts:
+            - description:
+              snippet_tags:
+                - python.example_code.sesv2.SESv2Wrapper.decl
+                - python.example_code.sesv2.GetEmailIdentityAttachment
     Rust:
       versions:
         - sdk_version: 1
@@ -163,7 +172,7 @@ sesv2_ListContacts:
     Python:
       versions:
         - sdk_version: 3
-          github: python/example_code/sesv2
+          github: python/example_code/sesv2/newsletter_scenario
           excerpts:
             - description:
               genai: most
@@ -234,7 +243,14 @@ sesv2_SendEmail:
     Python:
       versions:
         - sdk_version: 3
-          github: python/example_code/sesv2
+          github: python/example_code/sesv2/attachments_scenario
+          excerpts:
+            - description: Sends a message with optional attachments.
+              snippet_tags:
+                - python.example_code.sesv2.SESv2Wrapper.decl
+                - python.example_code.sesv2.SendEmailAttachment
+        - sdk_version: 3
+          github: python/example_code/sesv2/newsletter_scenario
           excerpts:
             - description: Sends a message to all members of the contact list.
               genai: most
@@ -282,7 +298,14 @@ sesv2_CreateEmailIdentity:
     Python:
       versions:
         - sdk_version: 3
-          github: python/example_code/sesv2
+          github: python/example_code/sesv2/attachments_scenario
+          excerpts:
+            - description:
+              snippet_tags:
+                - python.example_code.sesv2.SESv2Wrapper.decl
+                - python.example_code.sesv2.CreateEmailIdentityAttachment
+        - sdk_version: 3
+          github: python/example_code/sesv2/newsletter_scenario
           excerpts:
             - description:
               genai: most
@@ -333,7 +356,14 @@ sesv2_CreateEmailTemplate:
     Python:
       versions:
         - sdk_version: 3
-          github: python/example_code/sesv2
+          github: python/example_code/sesv2/attachments_scenario
+          excerpts:
+            - description:
+              snippet_tags:
+                - python.example_code.sesv2.SESv2Wrapper.decl
+                - python.example_code.sesv2.CreateEmailTemplateAttachment
+        - sdk_version: 3
+          github: python/example_code/sesv2/newsletter_scenario
           excerpts:
             - description:
               genai: most
@@ -384,7 +414,7 @@ sesv2_DeleteContactList:
     Python:
       versions:
         - sdk_version: 3
-          github: python/example_code/sesv2
+          github: python/example_code/sesv2/newsletter_scenario
           excerpts:
             - description:
               genai: most
@@ -435,7 +465,14 @@ sesv2_DeleteEmailIdentity:
     Python:
       versions:
         - sdk_version: 3
-          github: python/example_code/sesv2
+          github: python/example_code/sesv2/attachments_scenario
+          excerpts:
+            - description:
+              snippet_tags:
+                - python.example_code.sesv2.SESv2Wrapper.decl
+                - python.example_code.sesv2.DeleteEmailIdentityAttachment
+        - sdk_version: 3
+          github: python/example_code/sesv2/newsletter_scenario
           excerpts:
             - description:
               genai: most
@@ -486,7 +523,14 @@ sesv2_DeleteEmailTemplate:
     Python:
       versions:
         - sdk_version: 3
-          github: python/example_code/sesv2
+          github: python/example_code/sesv2/attachments_scenario
+          excerpts:
+            - description:
+              snippet_tags:
+                - python.example_code.sesv2.SESv2Wrapper.decl
+                - python.example_code.sesv2.DeleteEmailTemplateAttachment
+        - sdk_version: 3
+          github: python/example_code/sesv2/newsletter_scenario
           excerpts:
             - description:
               genai: most
@@ -544,7 +588,7 @@ sesv2_NewsletterWorkflow:
     Python:
       versions:
         - sdk_version: 3
-          github: python/example_code/sesv2
+          github: python/example_code/sesv2/newsletter_scenario
           excerpts:
             - description:
               genai: most
@@ -581,3 +625,59 @@ sesv2_NewsletterWorkflow:
   services:
     sesv2: {CreateContactList, CreateContact, ListContacts, SendEmail.simple, SendEmail.template, CreateEmailIdentity, CreateEmailTemplate,
             DeleteContactList, DeleteEmailIdentity, DeleteEmailTemplate}
+
+sesv2_Hello:
+  title: Hello &SESv2;
+  title_abbrev: Hello &SESv2;
+  synopsis: get started using &SESv2;.
+  category: Hello
+  languages:
+    Python:
+      versions:
+        - sdk_version: 3
+          github: python/example_code/sesv2/attachments_scenario
+          excerpts:
+            - description:
+              snippet_tags:
+                - python.example_code.sesv2.Hello
+  services:
+    sesv2: {ListEmailIdentities}
+sesv2_SendBulkEmail:
+  languages:
+    Python:
+      versions:
+        - sdk_version: 3
+          github: python/example_code/sesv2/attachments_scenario
+          excerpts:
+            - description:
+              snippet_tags:
+                - python.example_code.sesv2.SESv2Wrapper.decl
+                - python.example_code.sesv2.SendBulkEmail
+  services:
+    sesv2: {SendBulkEmail}
+sesv2_Scenario_EmailAttachments:
+  title: Send emails with attachments using &SESv2;
+  title_abbrev: Email Attachments Scenario
+  synopsis: send emails with attachments using &SESv2;.
+  synopsis_list:
+    - Verify sender email identity.
+    - Create an email template for bulk sends.
+    - Send a simple email with a file attachment.
+    - Send a simple email with an inline image.
+    - Send bulk templated emails with attachments.
+    - Clean up resources.
+  category: Scenarios
+  languages:
+    Python:
+      versions:
+        - sdk_version: 3
+          github: python/example_code/sesv2/attachments_scenario
+          excerpts:
+            - description: Run an interactive scenario demonstrating email attachments.
+              snippet_tags:
+                - python.example_code.sesv2.Scenario_EmailAttachments
+            - description: Create an SESv2 wrapper class to manage operations.
+              snippet_tags:
+                - python.example_code.sesv2.SESv2Wrapper.class
+  services:
+    sesv2: {SendEmail, SendBulkEmail, CreateEmailIdentity, CreateEmailTemplate, GetEmailIdentity, DeleteEmailTemplate, DeleteEmailIdentity}

.gitignore

@@ -41,3 +41,4 @@ kotlin/services/**/.kotlin/
 .kiro/settings/
 .kiro/steering/
 
+/codeloom_outputs

gov2/s3/actions/bucket_basics.go

@@ -14,10 +14,11 @@ import (
 	"io"
 	"log"
 	"os"
+	"sync"
 	"time"
 
 	"github.com/aws/aws-sdk-go-v2/aws"
-	"github.com/aws/aws-sdk-go-v2/feature/s3/manager"
+	"github.com/aws/aws-sdk-go-v2/feature/s3/transfermanager"
 	"github.com/aws/aws-sdk-go-v2/service/s3"
 	"github.com/aws/aws-sdk-go-v2/service/s3/types"
 	"github.com/aws/smithy-go"
@@ -162,15 +163,15 @@ func (basics BucketBasics) UploadFile(ctx context.Context, bucketName string, ob
 
 // snippet-start:[gov2.s3.Upload]
 
-// UploadLargeObject uses an upload manager to upload data to an object in a bucket.
-// The upload manager breaks large data into parts and uploads the parts concurrently.
+// UploadLargeObject uses the S3 transfer manager to upload data to an object in a bucket.
+// The transfer manager breaks large data into parts and uploads the parts concurrently.
 func (basics BucketBasics) UploadLargeObject(ctx context.Context, bucketName string, objectKey string, largeObject []byte) error {
 	largeBuffer := bytes.NewReader(largeObject)
 	var partMiBs int64 = 10
-	uploader := manager.NewUploader(basics.S3Client, func(u *manager.Uploader) {
-		u.PartSize = partMiBs * 1024 * 1024
+	tm := transfermanager.New(basics.S3Client, func(o *transfermanager.Options) {
+		o.PartSizeBytes = partMiBs * 1024 * 1024
 	})
-	_, err := uploader.Upload(ctx, &s3.PutObjectInput{
+	_, err := tm.UploadObject(ctx, &transfermanager.UploadObjectInput{
 		Bucket: aws.String(bucketName),
 		Key:    aws.String(objectKey),
 		Body:   largeBuffer,
@@ -234,18 +235,19 @@ func (basics BucketBasics) DownloadFile(ctx context.Context, bucketName string,
 
 // snippet-start:[gov2.s3.Download]
 
-// DownloadLargeObject uses a download manager to download an object from a bucket.
-// The download manager gets the data in parts and writes them to a buffer until all of
+// DownloadLargeObject uses the S3 transfer manager to download an object from a bucket.
+// The transfer manager gets the data in parts and writes them to a buffer until all of
 // the data has been downloaded.
 func (basics BucketBasics) DownloadLargeObject(ctx context.Context, bucketName string, objectKey string) ([]byte, error) {
 	var partMiBs int64 = 10
-	downloader := manager.NewDownloader(basics.S3Client, func(d *manager.Downloader) {
-		d.PartSize = partMiBs * 1024 * 1024
+	tm := transfermanager.New(basics.S3Client, func(o *transfermanager.Options) {
+		o.PartSizeBytes = partMiBs * 1024 * 1024
 	})
-	buffer := manager.NewWriteAtBuffer([]byte{})
-	_, err := downloader.Download(ctx, buffer, &s3.GetObjectInput{
-		Bucket: aws.String(bucketName),
-		Key:    aws.String(objectKey),
+	buffer := NewWriteAtBuffer([]byte{})
+	_, err := tm.DownloadObject(ctx, &transfermanager.DownloadObjectInput{
+		Bucket:   aws.String(bucketName),
+		Key:      aws.String(objectKey),
+		WriterAt: buffer,
 	})
 	if err != nil {
 		log.Printf("Couldn't download large object from %v:%v. Here's why: %v\n",
@@ -254,6 +256,38 @@ func (basics BucketBasics) DownloadLargeObject(ctx context.Context, bucketName s
 	return buffer.Bytes(), err
 }
 
+// WriteAtBuffer is a thread-safe in-memory io.WriterAt implementation.
+type WriteAtBuffer struct {
+	buf []byte
+	m   sync.Mutex
+}
+
+// NewWriteAtBuffer creates a new WriteAtBuffer with an initial byte slice.
+func NewWriteAtBuffer(buf []byte) *WriteAtBuffer {
+	return &WriteAtBuffer{buf: buf}
+}
+
+// WriteAt writes len(p) bytes to the buffer starting at byte offset off.
+func (b *WriteAtBuffer) WriteAt(p []byte, off int64) (int, error) {
+	b.m.Lock()
+	defer b.m.Unlock()
+	end := int(off) + len(p)
+	if end > len(b.buf) {
+		newBuf := make([]byte, end)
+		copy(newBuf, b.buf)
+		b.buf = newBuf
+	}
+	copy(b.buf[off:], p)
+	return len(p), nil
+}
+
+// Bytes returns the contents of the buffer.
+func (b *WriteAtBuffer) Bytes() []byte {
+	b.m.Lock()
+	defer b.m.Unlock()
+	return b.buf
+}
+
 // snippet-end:[gov2.s3.Download]
 
 // snippet-start:[gov2.s3.CopyObject]

gov2/s3/cmd/main.go

@@ -24,7 +24,7 @@ import (
 //     Amazon Simple Storage Service (Amazon S3) actions to work with
 //     S3 buckets and objects.
 //   - `largeobjects` - Runs the interactive large objects scenario that shows you how to upload
-//     and download large objects by using a transfer manager.
+//     and download large objects by using the S3 transfer manager.
 //   - `presigning` - 	Runs the interactive presigning scenario that shows you how to
 //     get presigned requests that contain temporary credentials
 //     and can be used to make requests from any HTTP client.

gov2/s3/go.mod

@@ -5,7 +5,7 @@ go 1.24
 require (
 	github.com/aws/aws-sdk-go-v2 v1.41.5
 	github.com/aws/aws-sdk-go-v2/config v1.27.33
-	github.com/aws/aws-sdk-go-v2/feature/s3/manager v1.17.18
+	github.com/aws/aws-sdk-go-v2/feature/s3/transfermanager v0.1.18
 	github.com/aws/aws-sdk-go-v2/service/s3 v1.97.3
 	github.com/aws/smithy-go v1.24.2
 	github.com/awsdocs/aws-doc-sdk-examples/gov2/demotools v0.0.0-20240907001412-a9375541143b

gov2/s3/scenarios/scenario_large_objects.go

@@ -21,8 +21,8 @@ import (
 // Simple Storage Service (Amazon S3) to upload and download large objects.
 //
 // 1. Create a bucket.
-// 3. Upload a large object to the bucket by using an upload manager.
-// 5. Download a large object by using a download manager.
+// 3. Upload a large object to the bucket by using the S3 transfer manager.
+// 5. Download a large object by using the S3 transfer manager.
 // 8. Delete all objects in the bucket.
 // 9. Delete the bucket.
 //

gov2/s3/scenarios/scenario_large_objects_test.go

@@ -30,7 +30,7 @@ func TestRunLargeObjectScenario(t *testing.T) {
 	testtools.RunScenarioTests(&scenTest, t)
 }
 
-// httpErr is used to mock an HTTP error. This is required by the download manager,
+// httpErr is used to mock an HTTP error. This is required by the transfer manager,
 // which calls GetObject until it receives a 415 status code.
 type httpErr struct {
 	statusCode int

gov2/workflows/s3_object_lock/actions/s3_actions.go

@@ -15,7 +15,7 @@ import (
 	"time"
 
 	"github.com/aws/aws-sdk-go-v2/aws"
-	"github.com/aws/aws-sdk-go-v2/feature/s3/manager"
+	"github.com/aws/aws-sdk-go-v2/feature/s3/transfermanager"
 	"github.com/aws/aws-sdk-go-v2/service/s3"
 	"github.com/aws/aws-sdk-go-v2/service/s3/types"
 	"github.com/aws/smithy-go"
@@ -24,7 +24,7 @@ import (
 // S3Actions wraps S3 service actions.
 type S3Actions struct {
 	S3Client  *s3.Client
-	S3Manager *manager.Uploader
+	S3Manager *transfermanager.Client
 }
 
 // snippet-end:[gov2.workflows.s3.ObjectLock.S3Actions.struct]
@@ -303,16 +303,16 @@ func (actor S3Actions) PutObjectRetention(ctx context.Context, bucket string, ke
 
 // snippet-start:[gov2.workflows.s3.ObjectLock.UploadObject]
 
-// UploadObject uses the S3 upload manager to upload an object to a bucket.
+// UploadObject uses the S3 transfer manager to upload an object to a bucket.
 func (actor S3Actions) UploadObject(ctx context.Context, bucket string, key string, contents string) (string, error) {
 	var outKey string
-	input := &s3.PutObjectInput{
+	input := &transfermanager.UploadObjectInput{
 		Bucket:            aws.String(bucket),
 		Key:               aws.String(key),
 		Body:              bytes.NewReader([]byte(contents)),
-		ChecksumAlgorithm: types.ChecksumAlgorithmSha256,
+		ChecksumAlgorithm: "SHA256",
 	}
-	output, err := actor.S3Manager.Upload(ctx, input)
+	output, err := actor.S3Manager.UploadObject(ctx, input)
 	if err != nil {
 		var noBucket *types.NoSuchBucket
 		if errors.As(err, &noBucket) {