Consolidating from the boto3-examples repo

Author: nmagee

Pipfile

@@ -10,4 +10,4 @@ botocore = "*"
 [dev-packages]
 
 [requires]
-python_version = "3.8"
+python_version = "3.12"

Pipfile.lock

@@ -0,0 +1,9 @@
+import boto3
+
+ec2 = boto3.client('ec2')
+
+response = ec2.describe_instances()
+
+for r in response['Reservations']:
+    for i in r['Instances']:
+        print(i['InstanceId'])

dynamodb/dynamo-db-table.template dynamodb/cloudformation/dynamo-db-table.template

@@ -0,0 +1,30 @@
+import boto3
+
+client = boto3.client('ec2')
+
+response = client.run_instances(
+  ImageId='ami-02354e95b39ca8dec',
+  InstanceType='t2.micro',
+  KeyName='nem2p-cs4740',
+  SecurityGroupIds=[
+    'sg-0c5cf2cca6833f090',
+  ],
+  # SubnetId='subnet-b39b21c5',
+  DryRun=False,
+  MinCount=1,
+  MaxCount=1,
+  InstanceInitiatedShutdownBehavior='terminate',
+  TagSpecifications=[
+    {
+      'ResourceType': 'instance',
+      'Tags': [
+        {
+          'Key': 'Name',
+          'Value': 'boto3-created-instance'
+        },
+      ]
+    },
+  ]
+)
+
+print(response)

ec2/python3/describe-instances.py

@@ -0,0 +1,4 @@
+import boto3
+
+s3 = boto3.client('s3')
+s3.download_file('my-bucket', 'OBJECT_NAME', 'FILE_NAME')

ec2/python3/launch-ec2.py

@@ -0,0 +1,10 @@
+import boto3
+import json
+
+s3 = boto3.client('s3')
+
+response = s3.list_buckets()
+
+for x in response['Buckets']:
+    print(x['Name'])
+

ec2/python/run-instance.py ec2/python3/run-instance.py

@@ -0,0 +1,7 @@
+import boto3
+s3 = boto3.resource('s3')
+
+my_bucket = s3.Bucket('bucket_name')
+
+for file in my_bucket.objects.all():
+    print(file.key)

kinesis/kinesis-lambda-data-stream.template kinesis/cloudformation/kinesis-lambda-data-stream.template

@@ -0,0 +1,27 @@
+import logging
+import boto3
+from botocore.exceptions import ClientError
+import os
+
+
+def upload_file(file_name, bucket, object_name=None):
+    """Upload a file to an S3 bucket
+
+    :param file_name: File to upload
+    :param bucket: Bucket to upload to
+    :param object_name: S3 object name. If not specified then file_name is used
+    :return: True if file was uploaded, else False
+    """
+
+    # If S3 object_name was not specified, use file_name
+    if object_name is None:
+        object_name = os.path.basename(file_name)
+
+    # Upload the file
+    s3_client = boto3.client('s3')
+    try:
+        response = s3_client.upload_file(file_name, bucket, object_name)
+    except ClientError as e:
+        logging.error(e)
+        return False
+    return True

lambda/api-demo/.chalice/config.json lambda/python3/api-demo/.chalice/config.json

@@ -0,0 +1,12 @@
+#!/usr/bin/env python3
+
+import boto3
+
+sns = boto3.client('sns')
+
+response = sns.publish(
+    TopicArn="arn:aws:sns:us-east-1:440848399208:cs4740-notification",
+    Message="Hey there everybody, how's it going today?",
+    Subject="Testing testing"
+)
+print(response)

lambda/api-demo/.chalice/deployed/dev.json lambda/python3/api-demo/.chalice/deployed/dev.json

@@ -0,0 +1,10 @@
+#!/usr/bin/env python3
+
+import boto3
+
+sqs = boto3.client('sqs')
+
+response = sqs.create_queue(
+    QueueName='demo-queue',
+)
+print(response)

lambda/api-demo/.gitignore lambda/python3/api-demo/.gitignore

@@ -0,0 +1,10 @@
+#!/usr/bin/env python3
+
+import boto3
+
+sqs = boto3.client('sqs')
+
+response = sqs.delete_queue(
+    QueueUrl='https://queue.amazonaws.com/440848399208/demo-queue'
+)
+print(response)

lambda/api-demo/__pycache__/app.cpython-310.pyc lambda/python3/api-demo/__pycache__/app.cpython-310.pyc

@@ -0,0 +1,21 @@
+#!/usr/bin/env python3
+
+import boto3
+
+sqs = boto3.client('sqs')
+
+def check_message_count():
+    response = sqs.get_queue_attributes(
+        QueueUrl='https://queue.amazonaws.com/440848399208/demo-queue',
+        AttributeNames=[
+          'All',
+        ]
+    )
+    anom = response['Attributes']['ApproximateNumberOfMessages']
+    if ( int(anom) >=1 ):
+      print("Count: " + anom + " Greater than or = to 1!")
+    else:
+      print("No messages available.")
+    print(response)
+
+check_message_count()

lambda/api-demo/app.py lambda/python3/api-demo/app.py

@@ -0,0 +1,10 @@
+#!/usr/bin/env python3
+
+import boto3
+
+sqs = boto3.client('sqs')
+
+response = sqs.purge_queue(
+    QueueUrl='https://queue.amazonaws.com/440848399208/demo-queue'
+)
+print(response)

lambda/api-demo/chalicelib/__init__.py lambda/python3/api-demo/chalicelib/__init__.py

@@ -0,0 +1,51 @@
+#!/usr/bin/env python3
+
+import boto3
+
+sqs = boto3.client('sqs')
+
+def check_message_count():
+    response = sqs.get_queue_attributes(
+        QueueUrl='https://queue.amazonaws.com/440848399208/demo-queue',
+        AttributeNames=[
+          'All',
+        ]
+    )
+    anom = response['Attributes']['ApproximateNumberOfMessages']
+    if ( int(anom) >=1 ):
+      print("Count: " + anom + " Greater than or = to 1!")
+      get_message()
+    else:
+      print("No messages available.")
+
+
+def delete_message(handle):
+    response = sqs.delete_message(
+        QueueUrl='https://queue.amazonaws.com/440848399208/demo-queue',
+        ReceiptHandle=handle
+    )
+
+def get_message():
+    try:
+      response = sqs.receive_message(
+        QueueUrl='https://queue.amazonaws.com/440848399208/demo-queue',
+        AttributeNames=['All'],
+        MessageAttributeNames=[
+            'project',
+        ],
+        MaxNumberOfMessages=1,
+        VisibilityTimeout=30,
+        WaitTimeSeconds=20,
+      )['Messages'][0]
+      messageid = response['MessageId']
+      handle = response['ReceiptHandle']
+      project = response['MessageAttributes']['project']['StringValue']
+      print("MessageID: " + messageid)
+      # print("Handle: " + handle)
+      print("Project: " + project)
+      print(response)
+      delete_message(handle)
+    except:
+        print("Nothing to see here")
+
+check_message_count()

lambda/api-demo/requirements-dev.txt lambda/python3/api-demo/requirements-dev.txt

@@ -0,0 +1,17 @@
+#!/usr/bin/env python3
+
+import boto3
+
+sqs = boto3.client('sqs')
+
+response = sqs.send_message(
+    QueueUrl='https://queue.amazonaws.com/440848399208/demo-queue',
+    MessageBody='body goes here 12345',
+    MessageAttributes={
+        'project': {
+            'StringValue': 'research',
+            'DataType': 'String'
+        }
+    }
+)
+print(response)