|
|
@@ -1,4 +1,5 @@
|
|
|
from minio import Minio
|
|
|
+import os
|
|
|
|
|
|
|
|
|
client = Minio(
|
|
|
@@ -8,22 +9,28 @@ client = Minio(
|
|
|
secure=False
|
|
|
)
|
|
|
|
|
|
-bucket_name = "grading"
|
|
|
+MINIO_ENDPOINT = "192.168.77.249:9000"
|
|
|
+MINIO_BUCKET = "grading"
|
|
|
+MINIO_BASE_PREFIX = "raspi_img_data"
|
|
|
|
|
|
+DATA_HOST_URL = f"http://{MINIO_ENDPOINT}/{MINIO_BUCKET}/{MINIO_BASE_PREFIX}"
|
|
|
|
|
|
-try:
|
|
|
- # 2. 检查存储桶是否存在
|
|
|
- found = client.bucket_exists(bucket_name)
|
|
|
- if not found:
|
|
|
- client.make_bucket(bucket_name)
|
|
|
- print(f"存储桶 {bucket_name} 已创建")
|
|
|
- else:
|
|
|
- print(f"存储桶 {bucket_name} 已存在")
|
|
|
|
|
|
- # 4. 列出该目录(桶)下的所有文件
|
|
|
- objects = client.list_objects(bucket_name, recursive=True)
|
|
|
- for obj in objects:
|
|
|
- print(f"对象名称: {obj.object_name}, 大小: {obj.size} bytes")
|
|
|
+# try:
|
|
|
+# # 2. 检查存储桶是否存在
|
|
|
+# found = client.bucket_exists(bucket_name)
|
|
|
+# if not found:
|
|
|
+# client.make_bucket(bucket_name)
|
|
|
+# print(f"存储桶 {bucket_name} 已创建")
|
|
|
+# else:
|
|
|
+# print(f"存储桶 {bucket_name} 已存在")
|
|
|
+#
|
|
|
+# cloud_path = os.path.join(data_dir, object_name).replace("\\", "/")
|
|
|
+#
|
|
|
+# client.fput_object(bucket_name, cloud_path, img_path, content_type="image/jpeg")
|
|
|
+# print(f"成功上传 {object_name} 到 {bucket_name}")
|
|
|
|
|
|
-except Exception as e:
|
|
|
- print(f"发生错误: {e}")
|
|
|
+
|
|
|
+
|
|
|
+# except Exception as e:
|
|
|
+# print(f"发生错误: {e}")
|