通过SCF回调COS上传对象信息到业务接口

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
import urllib
import urllib2

logging.basicConfig(level=logging.INFO, stream=sys.stdout)
logger = logging.getLogger()

appid=[这里换成自己的appid] #appid

def main_handler(event, context):
    logger.info("start main handler")
    for record in event['Records']:
        try:
            #这里是通过COS事件，拆分客户端上传额请求信息
            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)

            try:
                #这里是请求业务服务器的内容
                objectname = urllib.quote_plus(key)
                url = "http://[业务服务器IP或域名]/?objectname="+objectname #应用服务器接口地址                
                res_data = urllib2.urlopen(url)
                res = res_data.read()
                print url

            except CosServiceError as e:
                print(e.get_error_code())
                print(e.get_error_msg())
                print(e.get_resource_location())
                return "Fail"
            logger.info("callback server [%s] Success" % key)

        except Exception as e:
            print(e)
            print('Error callback server {} from bucket {}. '.format(key, bucket))
            raise e
            return "Fail"

    return "Success"