Python實現上傳Minio和阿裡Oss文件
前言
本文提供Python上傳minio以及阿裡oss文件工具,給自己留個記錄。
環境依賴
安裝minio以及oss2依賴
pip install minio -i https://pypi.douban.com/simple pip install oss2 -i https://pypi.douban.com/simple
代碼
#!/usr/bin/env python # -*- coding: utf-8 -*- # @Time : 2021/12/10 21:35 # @Author : 劍客阿良_ALiang # @Site : # @File : upload_tool.py # !/user/bin/env python # coding=utf-8 """ @project : dh_train @author : huyi @file : remote_upload_util.py @ide : PyCharm @time : 2021-12-10 14:58:29 """ import traceback from minio import Minio from minio.error import S3Error import oss2 def minio_file_upload(end_point: str, access_key: str, secret_key: str, bucket: str, remote_path: str, local_path: str): try: _end_point = end_point.replace('https://', '').replace('http://', '') # Create a client with the MinIO server playground, its access key # and secret key. client = Minio( _end_point, access_key=access_key, secret_key=secret_key, secure=False ) # Make 'asiatrip' bucket if not exist. found = client.bucket_exists(bucket) if not found: client.make_bucket(bucket) else: print("Bucket {} already exists".format(bucket)) # Upload '/home/user/Photos/asiaphotos.zip' as object name # 'asiaphotos-2015.zip' to bucket 'asiatrip'. client.fput_object( bucket, remote_path, local_path, ) print( "{} is successfully uploaded as " "object {} to bucket {}.".format(local_path, remote_path, bucket) ) except S3Error as e: print( "*** minio上傳文件異常 -> {} {}".format(str(e), traceback.format_exc())) raise Exception("minio上傳文件異常:[{}]".format(str(e))) def oss_file_upload(end_point: str, access_key: str, secret_key: str, bucket: str, remote_path: str, local_path: str): try: _end_point = end_point.replace('https://', '').replace('http://', '') # 阿裡雲賬號AccessKey擁有所有API的訪問權限,風險很高。強烈建議您創建並使用RAM用戶進行API訪問或日常運維,請登錄RAM控制臺創建RAM用戶。 auth = oss2.Auth(access_key, secret_key) # yourEndpoint填寫Bucket所在地域對應的Endpoint。以華東1(杭州)為例,Endpoint填寫為https://oss-cn-hangzhou.aliyuncs.com。 # 填寫Bucket名稱。 bucket = oss2.Bucket(auth, _end_point, bucket) # 填寫Object完整路徑和本地文件的完整路徑。Object完整路徑中不能包含Bucket名稱。 # 如果未指定本地路徑,則默認從示例程序所屬項目對應本地路徑中上傳文件。 bucket.put_object_from_file(remote_path, local_path) except S3Error as e: print( "*** oss上傳文件異常 -> {} {}".format(str(e), traceback.format_exc())) raise Exception("oss上傳文件異常:[{}]".format(str(e)))
代碼說明:
1、參數分別為endpoint(IP或者域名:端口)、accessKey、secretKey、桶名、遠程文件路徑、本地文件路徑。
補充
Python實現Minio的下載(主要用於異地備份的中轉站)
import logging
from minio import Minio
from minio.error import S3Error
logging.basicConfig(
level=logging.INFO,
filename='../mysqlbackup_downlaod.log',
filemode='a',
format='%(asctime)s %(name)s %(levelname)s--%(message)s'
)
file_name = "mysql_monitor.py"
file_path = "C:\\Users\\lpy\\Desktop\\img\\{}".format(file_name)
def download_file():
# 創建一個客戶端
minioClient = Minio(
'minio.***.com',
access_key='admin',
secret_key='****',
secure=False
)
try:
minioClient.fget_object(
bucket_name="backup",
object_name="mysql/dev/{}".format(file_name),
file_path=file_path
)
logging.info("file '{0}' is successfully download".format(file_name))
except S3Error as err:
logging.error("download_failed:", err)
if __name__ == '__main__':
download_file()
以上就是Python實現上傳Minio和阿裡Oss文件的詳細內容,更多關於Python上傳Minio 阿裡Oss文件的資料請關註WalkonNet其它相關文章!
推薦閱讀:
- Minio設置文件鏈接永久有效的完整步驟
- 輕量級對象存儲服務minio安裝及瀏覽器使用教程
- Docker安裝MinIO詳細步驟介紹
- Minio基本介紹及如何搭建Minio集群
- Python之根據輸入參數計算結果案例講解