xdc20201211/py/s3+lambda+sqs.py

from PIL import Image
import json
import sys
import boto3

def lambda_handler(event, context):
    sqs_client = boto3.client('sqs')
    s3 = boto3.resource('s3')
    body = event['Records'][0]['body']
    body_events = json.loads(body)

    bucket_name = body_events['Records'][0]['s3']['bucket']['name']
    bucket_file = body_events['Records'][0]['s3']['object']['key']
    s3.meta.client.download_file(bucket_name, bucket_file, '/tmp/{}'.format(bucket_file))

    img = Image.open('/tmp/{}'.format(bucket_file))
    img1 = img.convert('L')
    img1.save('/tmp/{}'.format(bucket_file))
    img.close()
    bucket2 = 'xctestdel'

    s3.meta.client.upload_file('/tmp/{}'.format(bucket_file), bucket2, 'xcloud/{}'.format(bucket_file))