COS结合SCF的数据复制实践

# -*- coding: utf8 -*-
# SCF configures the COS trigger, obtains the file uploading information from COS, and downloads it to the local temporary disk 'tmp' of SCF.
# SCF配置COS触发，从COS获取文件上传信息，并下载到SCF的本地临时磁盘tmp
from qcloud_cos_v5 import CosConfig
from qcloud_cos_v5 import CosS3Client
from qcloud_cos_v5 import CosServiceError
from qcloud_cos_v5 import CosClientError
import sys
import logging
logging.basicConfig(level=logging.INFO, stream=sys.stdout)
appid = 1259680000 # Please replace with your APPID. 请替换为您的 APPID
secret_id = u'AKIDXszKUScWAAHL9ggA1e3HFxPbbrXXX' # 请替换为您的 SecretId
secret_key = u'3d1A6FB2FBqFRQ9nRqzsVrwoRxXXXX' # 请替换为您的 SecretKey
region = u'ap-beijing' # Please replace with the region where COS bucket located. 请替换为您bucket 所在的地域
token = ''
config = CosConfig(Secret_id=secret_id, Secret_key=secret_key, Region=region, Token=token)
client = CosS3Client(config)
logger = logging.getLogger()
def main_handler(event, context):
    logger.info("start main handler")
 for record in event['Records']:
 try:
            bucket = record['cos']['cosBucket']['name'] + '-' + str(appid)
            key = record['cos']['cosObject']['key']
            key = key.replace('/' + str(appid) + '/' + record['cos']['cosBucket']['name'] + '/', '', 1)
            logger.info("Key is " + key)
 # copy object from cos
            logger.info("Get from [%s] to download file [%s]" % (bucket, key))
            download_path = '/tmp/{}'.format(key)
 try:
                response = client.copy(
                    Bucket='wainsunbj-1259681344', #这里是目标bucket
                    Key= key.replace('upload/', '', 1), #这里是目标对象名，我们这里把upload/替换为空，所以是复制到bucket根目录上
                    CopySource={
 'Bucket': bucket, 
 'Key': key, 
 'Region': 'ap-beijing'
                    }
                )
 except CosServiceError as e:
 print(e.get_error_code())
 print(e.get_error_msg())
 print(e.get_resource_location())
 return "Fail"
            logger.info("copy file [%s] Success" % key)
 except Exception as e:
 print(e)
 print('Error copy object {} from bucket {}. '.format(key, bucket))
 raise e
 return "Fail"
 return "Success"