source/use_cases/aws-s3-static-website/lib/lambda/copy_s3_objects.py [5:46]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
client = boto3.client('s3')

import logging
logger = logging.getLogger()
logger.setLevel(logging.INFO)

def on_event(event, context):
  logger.info("Received event: %s" % json.dumps(event))
  request_type = event['RequestType']
  if request_type == 'Create': return on_create(event)
  if request_type == 'Update': return on_create(event)
  if request_type == 'Delete': return on_delete(event)
  raise Exception("Invalid request type: %s" % request_type)

def on_create(event):
  source_bucket = event['ResourceProperties']['SourceBucket']
  source_prefix = event['ResourceProperties'].get('SourcePrefix') or ''
  bucket = event['ResourceProperties']['Bucket']
  prefix = event['ResourceProperties'].get('Prefix') or ''
  try:
    copy_objects(source_bucket, source_prefix, bucket, prefix)
  except ClientError as e:
    logger.error('Error: %s', e)
    raise e
  return

def on_delete(event):
  bucket = event['ResourceProperties']['Bucket']
  prefix = event['ResourceProperties'].get('Prefix') or ''
  try:
    delete_objects(bucket, prefix)
  except ClientError as e:
    logger.error('Error: %s', e)
    raise e
  return

def copy_objects(source_bucket, source_prefix, bucket, prefix):
  paginator = client.get_paginator('list_objects_v2')
  page_iterator = paginator.paginate(Bucket=source_bucket, Prefix=source_prefix)
  for key in {x['Key'] for page in page_iterator for x in page['Contents']}:
    dest_key = os.path.join(prefix, os.path.relpath(key, source_prefix))
    if not key.endswith('/'):
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



source/use_cases/aws-serverless-web-app/lib/lambda/static-content/copy_s3_objects.py [5:46]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
client = boto3.client('s3')

import logging
logger = logging.getLogger()
logger.setLevel(logging.INFO)

def on_event(event, context):
  logger.info("Received event: %s" % json.dumps(event))
  request_type = event['RequestType']
  if request_type == 'Create': return on_create(event)
  if request_type == 'Update': return on_create(event)
  if request_type == 'Delete': return on_delete(event)
  raise Exception("Invalid request type: %s" % request_type)

def on_create(event):
  source_bucket = event['ResourceProperties']['SourceBucket']
  source_prefix = event['ResourceProperties'].get('SourcePrefix') or ''
  bucket = event['ResourceProperties']['Bucket']
  prefix = event['ResourceProperties'].get('Prefix') or ''
  try:
    copy_objects(source_bucket, source_prefix, bucket, prefix)
  except ClientError as e:
    logger.error('Error: %s', e)
    raise e
  return

def on_delete(event):
  bucket = event['ResourceProperties']['Bucket']
  prefix = event['ResourceProperties'].get('Prefix') or ''
  try:
    delete_objects(bucket, prefix)
  except ClientError as e:
    logger.error('Error: %s', e)
    raise e
  return

def copy_objects(source_bucket, source_prefix, bucket, prefix):
  paginator = client.get_paginator('list_objects_v2')
  page_iterator = paginator.paginate(Bucket=source_bucket, Prefix=source_prefix)
  for key in {x['Key'] for page in page_iterator for x in page['Contents']}:
    dest_key = os.path.join(prefix, os.path.relpath(key, source_prefix))
    if not key.endswith('/'):
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -