ASJServer/Ansjer/test/osssigput.py

#!/usr/bin/env python3  
# -*- coding: utf-8 -*-  
"""
@Copyright (C) ansjer cop Video Technology Co.,Ltd.All rights reserved.
@AUTHOR: ASJRD018
@NAME: AnsjerFormal
@software: PyCharm
@DATE: 2018/11/8 9:23
@Version: python3.6
@MODIFY DECORD:ansjer dev
@file: oss_sts.py
@Contact: chanjunkai@163.com
"""
# -*- coding: utf-8 -*-
'''
生成sts上传授权
'''
from aliyunsdkcore import client
from aliyunsdksts.request.v20150401 import AssumeRoleRequest
import json
import oss2

endpoint = 'oss-cn-shenzhen.aliyuncs.com'

bucket_name = 'testrtmp'

tokenss={
  "AccessKeyId": "STS.NJkdiiu9PMUdGaXFiSnS83WRM",
  "AccessKeySecret": "HvrWLseaz257Nz37PYCAioVEYEKNaf8JZXYW855VNcnC",
  "SecurityToken": "CAIS1AJ1q6Ft5B2yfSjIr4neL9PdmOZx+pePRUfpomkGYtwU3JL5rzz2IHxLf3RuAe8dvvw+nGBV7vsdlqN4S5ZDR1HCbsJxtjm5Bbo6J9ivgde8yJBZolnMewHKedCSvqL7Z+H+U6mMGJOEYEzFkSle2KbzcS7YMXWuLZyOj+wuDLEQRRLqVSdaI91UKwB+yrcdLmCDGfupPwLnpWDSAUF0wFYe71ly8qOi2MaRxwPDhVnhsI8vqp/2P4KvYrscXul2WMzn2/dtJOiTknxM5gNW7rtzlOsGg3Ol3/CFKlVd+RidKJCw+9Z0fjR+e7IxFo9c3oGe8qQi4qqJzNuxkksSe7gFDwanHdj6nJGfR7jzbY1iLe2gYk6giI7fasPH1Co/em8eOQ9wfN4sF2R9ExRESEuBdvD8pQ6SPVzzE/ndgPxujMVvr1Dh7dOGIlmJU0Y3c+Dtox9VGoABY3pOaapVaGXulEwkKgzcs1uHjyWuydn19BNRh4/VGrMUJnaUziXMDBN/3ui8trV3/UqSqlo65BZ5LEr7KawatcwC+qdbTY4DfwhUkBfDW/WSuCQGyMPjhpIjXTG5rek3YGp7+ocqB5e2truXo6aBdsD/g8xICFwLA9vAP5AuCLE=",
  "Expiration": "2018-11-22T06:41:34Z",
  "expire": 3600,
  "endpoint": "oss-cn-shenzhen.aliyuncs.com",
  "bucket_name": "testrtmp",
  "arn": "acs:ram::1024237323330331:role/maxadmin/chanjunkai"
}
# 使用RAM账号的AccessKeyId和AccessKeySecret向STS申请临时token。

# 使用临时token中的认证信息初始化StsAuth实例。
auth = oss2.StsAuth(tokenss['AccessKeyId'],
                    tokenss['AccessKeySecret'],
                    tokenss['SecurityToken'])
print(auth)
# exit()
# 使用StsAuth实例初始化存储空间。
bucket = oss2.Bucket(auth, endpoint, bucket_name)

# 上传一个字符串。
bucket.delete_object('a-3.txt')
exit()

bucket.put_object('a-3.txt', b'hello world')
exit()
res =bucket.get_object('object-name.txt')
print(res.read())