jim-my · September 3, 2020 11:42 · Aug 13, 2016 · Aug 13, 2016 · Aug 13, 2016 · Aug 13, 2016
diff --git a/ec2_list_instances_filtered.go b/ec2_list_instances_filtered.go
@@ -1,7 +1,5 @@
 package main
 
-/* https://github.com/aws/aws-sdk-go/wiki */
-
 import (
 	"fmt"
 	"log"
@@ -11,13 +9,7 @@ import (
 )
 
 func main() {
-	/*
-	   export AWS_REGION=""
-	   export AWS_ACCESS_KEY_ID=""
-	   export AWS_SECRET_ACCESS_KEY=""*/
-
 	ec2svc := ec2.New(session.New())
-
 	params := &ec2.DescribeInstancesInput{
 		Filters: []*ec2.Filter{
 			{

diff --git a/_aws_golang_examples → _aws_golang_examples.md b/_aws_golang_examples → _aws_golang_examples.md
diff --git a/_aws_golang_examples b/_aws_golang_examples
@@ -0,0 +1 @@
+## AWS Golang SDK examples
diff --git a/sqs_list_queues.go b/sqs_list_queues.go
@@ -0,0 +1,24 @@
+package main
+
+import (
+	"fmt"
+	"github.com/aws/aws-sdk-go/aws"
+	"github.com/aws/aws-sdk-go/aws/session"
+	"github.com/aws/aws-sdk-go/service/sqs"
+)
+
+func main() {
+	sqssvc := sqs.New(session.New())
+
+	params := &sqs.ListQueuesInput{
+		QueueNamePrefix: aws.String("prod-"),
+	}
+	sqs_resp, err := sqssvc.ListQueues(params)
+	if err != nil {
+		fmt.Println(err.Error())
+		return
+	}
+	for _, url := range sqs_resp.QueueUrls {
+		fmt.Println(*url)
+	}
+}
diff --git a/sqs_list_queue_attribs.go b/sqs_list_queue_attribs.go
@@ -0,0 +1,27 @@
+package main
+
+import (
+	"fmt"
+	"strconv"
+	"github.com/aws/aws-sdk-go/aws"
+	"github.com/aws/aws-sdk-go/aws/session"
+	"github.com/aws/aws-sdk-go/service/sqs"
+)
+
+func main() {
+	sqssvc := sqs.New(session.New())
+	params := &sqs.GetQueueAttributesInput{
+		QueueUrl: aws.String("https://sqs.<region>.amazonaws.com/<acc_number>/<queue_name>"),
+		AttributeNames: []*string{
+			aws.String("ApproximateNumberOfMessages"),
+			aws.String("ApproximateNumberOfMessagesDelayed"),
+			aws.String("ApproximateNumberOfMessagesNotVisible"),
+		},
+	}
+	resp, _ := sqssvc.GetQueueAttributes(params)
+	for attrib, _ := range resp.Attributes {
+		prop := resp.Attributes[attrib]
+		i, _ := strconv.Atoi(*prop)
+		fmt.Println(attrib, i)
+	}
+}
diff --git a/s3_list_keys.go b/s3_list_keys.go
@@ -0,0 +1,28 @@
+package main
+
+import (
+	"fmt"
+	"github.com/aws/aws-sdk-go/aws"
+	"github.com/aws/aws-sdk-go/aws/session"
+	"github.com/aws/aws-sdk-go/service/s3"
+)
+
+func main() {
+	s3svc := s3.New(session.New())
+	inputparams := &s3.ListObjectsInput{
+		Bucket:  aws.String("eferro-bucket"),
+		MaxKeys: aws.Int64(10),
+	}
+	pageNum := 0
+	s3svc.ListObjectsPages(inputparams, func(page *s3.ListObjectsOutput, lastPage bool) bool {
+		fmt.Println("Page", pageNum)
+		pageNum++
+		for _, value := range page.Contents {
+			fmt.Println(*value.Key)
+		}
+		fmt.Println("pageNum", pageNum, "lastPage", lastPage)
+
+		// return if we should continue with the next page
+		return true
+	})
+}
diff --git a/s3_list_buckets.go b/s3_list_buckets.go
@@ -0,0 +1,23 @@
+package main
+
+import (
+	"fmt"
+
+	"github.com/aws/aws-sdk-go/aws"
+	"github.com/aws/aws-sdk-go/aws/session"
+	"github.com/aws/aws-sdk-go/service/s3"
+)
+
+func main() {
+	s3svc := s3.New(session.New())
+	result, err := s3svc.ListBuckets(&s3.ListBucketsInput{})
+	if err != nil {
+		fmt.Println("Failed to list buckets", err)
+		return
+	}
+
+	fmt.Println("Buckets:")
+	for _, bucket := range result.Buckets {
+		fmt.Printf("%s : %s\n", aws.StringValue(bucket.Name), bucket.CreationDate)
+	}
+}
diff --git a/ec2_list_instances_filtered.go b/ec2_list_instances_filtered.go
@@ -0,0 +1,45 @@
+package main
+
+/* https://github.com/aws/aws-sdk-go/wiki */
+
+import (
+	"fmt"
+	"log"
+	"github.com/aws/aws-sdk-go/aws"
+	"github.com/aws/aws-sdk-go/aws/session"
+	"github.com/aws/aws-sdk-go/service/ec2"
+)
+
+func main() {
+	/*
+	   export AWS_REGION=""
+	   export AWS_ACCESS_KEY_ID=""
+	   export AWS_SECRET_ACCESS_KEY=""*/
+
+	ec2svc := ec2.New(session.New())
+
+	params := &ec2.DescribeInstancesInput{
+		Filters: []*ec2.Filter{
+			{
+				Name:   aws.String("tag:Environment"),
+				Values: []*string{aws.String("prod")},
+			},
+			{
+				Name:   aws.String("instance-state-name"),
+				Values: []*string{aws.String("running"), aws.String("pending")},
+			},
+		},
+	}
+	resp, err := ec2svc.DescribeInstances(params)
+	if err != nil {
+		fmt.Println("there was an error listing instances in", err.Error())
+		log.Fatal(err.Error())
+	}
+
+	for idx, res := range resp.Reservations {
+		fmt.Println("  > Reservation Id", *res.ReservationId, " Num Instances: ", len(res.Instances))
+		for _, inst := range resp.Reservations[idx].Instances {
+			fmt.Println("    - Instance ID: ", *inst.InstanceId)
+		}
+	}
+}