import json

import oss2

import requests

import time

def my_handler(event=None, context=None):

    # evt = json.loads(event)

    # creds = context.credentials

    # 身份验证时，请不要遗漏了 security_token！

    # Do not miss the "security_token" for the authentication!

    # auth = oss2.StsAuth(creds.access_key_id, creds.access_key_secret, creds.security_token)

    kid, ks, ep, bn = '', '', 'oss-cn-beijing.aliyuncs.com', 'img'

    # bucket = oss2.Bucket(auth, evt['endpoint'], evt['bucket'])

    # bucket.put_object(evt['objectName'], evt['message'])

    auth = oss2.Auth(kid, ks)

    bucket = oss2.Bucket(auth, ep, bn)

    url = 'http://www.baidu.com/ReQ3M.mp4'

    d = requests.get(url)

    bytes_ = d._content

    f = '{}{}'.format('', 'fw.mp4')

    # with open(f, 'wb') as fw:

    #     fw.write(bytes_)

    res = bucket.put_object(f, bytes_)

    print(res.resp.response.url)

    for obj in oss2.ObjectIterator(bucket):

        print(obj.key)

    return 'success'