aaa
This commit is contained in:
@@ -0,0 +1,39 @@
|
||||
from minio import Minio
|
||||
from minio.error import S3Error
|
||||
import io
|
||||
|
||||
# 1. 创建客户端
|
||||
client = Minio(
|
||||
'localhost:9100',
|
||||
access_key='minioadmin',
|
||||
secret_key='minioadmin',
|
||||
secure=False, # 本地测试用 HTTP;生产环境请用 True
|
||||
)
|
||||
|
||||
bucket_name = 'test-bucket'
|
||||
object_name = 'test-object'
|
||||
data = b'Hello MinIO'
|
||||
|
||||
try:
|
||||
# 2. 桶不存在就创建(关键修改)
|
||||
if not client.bucket_exists(bucket_name):
|
||||
client.make_bucket(bucket_name)
|
||||
print(f"已创建桶: {bucket_name}")
|
||||
|
||||
# 3. 上传对象,length 用 len(data) 动态计算
|
||||
client.put_object(
|
||||
bucket_name,
|
||||
object_name,
|
||||
io.BytesIO(data),
|
||||
length=len(data),
|
||||
)
|
||||
print(f"MinIO 连接成功,对象上传完成: {bucket_name}/{object_name}")
|
||||
|
||||
# 4. (可选)验证一下确实传上去了
|
||||
stat = client.stat_object(bucket_name, object_name)
|
||||
print(f"验证: 对象大小 = {stat.size} 字节")
|
||||
|
||||
except S3Error as e:
|
||||
print(f"S3 错误: code={e.code}, message={e.message}")
|
||||
except Exception as e:
|
||||
print(f"其它错误: {type(e).__name__}: {e}")
|
||||
Reference in New Issue
Block a user