from obs import CreateBucketHeader, HeadPermission
from obs import ObsClient
import os
import traceback

ak = "8KHDFEBOI24BNSROVPR9"
sk = "pKNE4ZRwcvqcgH2wkJhiautgv6m1Efh07vD6n4mY"
server = "https://100.125.2.61"

obsClient = ObsClient(access_key_id=ak, secret_access_key=sk, server=server)
try:
    header = CreateBucketHeader(aclControl=HeadPermission.PRIVATE, storageClass="STANDARD", availableZone="3az")
    location = "cn-northwest-6043"
    bucketName = "test-magic-media-store"
    # 创建桶
    resp = obsClient.createBucket(bucketName, header, location)
    if resp.status < 300:
        print('Create Bucket Succeeded')
        print('requestId:', resp.requestId)
    else:
        print('Create Bucket Failed')
        print('requestId:', resp.requestId)
        print('errorCode:', resp.errorCode)
        print('errorMessage:', resp.errorMessage)
except:
    print('Create Bucket Failed')
    print(traceback.format_exc())

# 跨域

from obs import ObsClient
from obs import CorsRule
import os
import traceback

ak = "8KHDFEBOI24BNSROVPR9"
sk = "pKNE4ZRwcvqcgH2wkJhiautgv6m1Efh07vD6n4mY"
server = "https://100.125.2.61"

# 创建obsClient实例
# 如果使用临时AKSK和SecurityToken访问OBS，需要在创建实例时通过security_token参数指定securityToken值
obsClient = ObsClient(access_key_id=ak, secret_access_key=sk, server=server)
try:
    # 指定Cors规则
    cors1 = CorsRule(id='rule1', allowedMethod=['PUT', 'POST', 'GET', 'DELETE', 'HEAD'],
                     allowedOrigin=['*'], allowedHeader=['*'], exposeHeader = ['ETag', 'Content-Type', 'Content-Length', 'Cache-Control', 'Content-Disposition', 'Content-Encoding', 'Content-Language', 'Expires', 'x-obs-request-id', 'x-obs-id-2', 'x-reserved-indicator', 'x-obs-api', 'x-obs-version-id', 'x-obs-copy-source-version-id', 'x-obs-storage-class', 'x-obs-delete-marker', 'x-obs-expiration', 'x-obs-website-redirect-location', 'x-obs-restore', 'x-obs-version', 'x-obs-object-type', 'x-obs-next-append-position'],
                     maxAgeSecond=60)
    corsList = [cors1]
    bucketName = "test-magic-media-store"
    # 设置桶的CORS配置
    resp = obsClient.setBucketCors(bucketName, corsList)

    # 返回码为2xx时，接口调用成功，否则接口调用失败
    if resp.status < 300:
        print('Set Bucket Cors Succeeded')
        print('requestId:', resp.requestId)
    else:
        print('Set Bucket Cors Failed')
        print('requestId:', resp.requestId)
        print('errorCode:', resp.errorCode)
        print('errorMessage:', resp.errorMessage)
except:
    print('Set Bucket Cors Failed')
    print(traceback.format_exc())