LambdaReplicator

LambdaMultiRegionCopy.js

console.log('Loading function');

const aws = require('aws-sdk');

const s3 = new aws.S3({ apiVersion: '2006-03-01' });


exports.handler = async (event, context) => {
    const bucket = event.Records[0].s3.bucket.name;
    const key = decodeURIComponent(event.Records[0].s3.object.key.replace(/\+/g, ' '));
    const params = {
        Bucket: bucket,
        Key: key,
    };
    const destRegions = [
        "euw1",
        "euc1",
        "use1",
        "usw2",
        "apse1",
        "apse2"
        ]
     const destParamsTemplate = {
      CopySource: "/" + bucket + "/" + key, 
      Key: key
     };
     var operations = []
    for (var i in destRegions) {
        const destParams = {}
        Object.assign(destParams, destParamsTemplate);
        destParams.Bucket = bucket + "-" + destRegions[i]
        console.log("Copy request with params: " + JSON.stringify(destParams))
        const regionPush = s3.copyObject(destParams).promise()
        operations.push(regionPush)
    }
    await Promise.allSettled(operations)
            .then((results) => results.forEach((result) => console.log(result)));
};