Перекрестный счет s3 bucket syn c с использованием лямбды (скрипт boto) - PullRequest
Новая
       6

Перекрестный счет s3 bucket syn c с использованием лямбды (скрипт boto)

0 голосов
/ 14 января 2020

Мне нужно синхронизировать c до 3 сегментов, которые находятся в разных учетных записях. Для этого я создаю 2 сегмента с политикой сегментов и функцией Lambda с политикой iam и триггером событий s3.

Я пытался через CLI . Можно ли как-нибудь помочь написать скрипт бота в syn c buckets

Я пытаюсь код ниже в лямбда- 

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

def sync_command(command):
    command_list = command.split(' ')

    try:
        logger.info("Running shell command: \"{}\"".format(command))
        result = subprocess.run(command_list, stdout=subprocess.PIPE);
        logger.info("Command output:\n---\n{}\n---".format(result.stdout.decode('UTF-8')))
    except Exception as e:
        logger.error("Exception: {}".format(e))
        return False

    return True

def lambda_handler(event, context):
    logger.info(event);
    SOURCE_BUCKET = os.environ['source']
    print('SOURCE_BUCKET:', SOURCE_BUCKET)
    TARGET_BUCKET = os.environ['target']
    print('TARGET_BUCKET:', TARGET_BUCKET)

    sync_command("aws s3 sync s3://source-bucket/ s3://destination-bucket/")

, но это показывает ошибку Исключение: [Errno 2] Нет такого файла или каталога: 'aws': 'aws

1 Ответ

0 голосов
/ 16 января 2020

Я сделал это, используя скрипт bob, вот код 

import subprocess
import logging
import boto3

def check(bucket, key):
    s3client = boto3.client("s3")
    s3 = boto3.resource('s3')

    copy_source = {
          'Bucket': bucket,
          'Key': key
        }

    print("key",key)
    bucket = s3.Bucket('target_bucket')
    bucket.copy(copy_source,key)


def lambda_handler(event, context):
   ev = event["Records"]
   bucketName = ev[0]["s3"]["bucket"]["name"]
   keyName = ev[0]["s3"]["object"]["key"]
   check(bucketName,keyName)

, работающий нормально в лямбде.

...