recommend-model/recommend-model-produce/src/main/python/tools/utils/oss_client.py

import oss2
import logging

logging.basicConfig(
    format='%(asctime)s - %(levelname)s - %(message)s', level=logging.INFO)
logger = logging.getLogger(__name__)

access_key_id="LTAI5tHMkNaRhpiDB1yWMZPn"
access_key_secret="XLi5YUJusVwbbQOaGeGsaRJ1Qyzbui"
auth = oss2.AuthV4(access_key_id, access_key_secret)

hangzhou_config = {
    "endpoint" : "https://oss-cn-hangzhou.aliyuncs.com",
    "inner_endpoint" : "https://oss-cn-hangzhou-internal.aliyuncs.com",
    "region" : "cn-hangzhou"
}

class HangZhouOSSClient:
    def __init__(self, bucket_name):
        self.bucket_name = bucket_name
        self.bucket = oss2.Bucket(auth, hangzhou_config["inner_endpoint"], bucket_name, region=hangzhou_config["region"])

    def put_object_from_file(self, object_name, local_file):
        result = self.bucket.put_object_from_file(object_name, local_file)
        logger.info("\n status: {} \n request_id: {} \n ETag: {} \n date: {}".format(result.status, result.request_id,
        result.etag, result.headers['date']))

if __name__ == "__main__":
    client = HangZhouOSSClient("art-recommend")
    client.put_object_from_file("dyp/stuuudy.pem", "/Users/dingyunpeng/stuuudy.pem")