GridFS.

GridFS 버킷 만들기

GridFS에서 파일을 저장하거나 조회하려면 버킷을 만들거나 MongoDB 데이터베이스에서 기존 버킷에 대한 참조를 가져오면 됩니다. GridFSBucket 인스턴스를 만들려면 데이터베이스 매개 변수를 사용하여 NewBucket() 메서드를 호출합니다.

db := client.Database("db")
bucket, err := gridfs.NewBucket(db)
if err != nil {
   panic(err)
}

기본적으로 새 버킷의 이름은 fs입니다. 사용자 지정 이름으로 버킷을 인스턴스화하려면 다음과 같이 BucketOptions 인스턴스에서 SetName() 메서드를 호출합니다.

db := client.Database("db")
opts := options.GridFSBucket().SetName("custom name")
bucket, err := gridfs.NewBucket(db, opts)
if err != nil {
   panic(err)
}

파일 업로드

다음 방법 중 하나를 사용하여 GridFS 버킷에 파일을 업로드할 수 있습니다.

• 입력 스트림에서 읽는 UploadFromStream() 메서드를 사용합니다.

• 출력 스트림에 쓰는 OpenUploadStream() 메서드를 사용합니다.

두 업로드 프로세스에서 UploadOptions 인스턴스에 대한 구성 정보를 지정할 수 있습니다. UploadOptions 필드의 전체 목록은 API 설명서를 참조하세요.

file, err := os.Open("path/to/file.txt")
uploadOpts := options.GridFSUpload().SetMetadata(bson.D{{"metadata tag", "first"}})
objectID, err := bucket.UploadFromStream("file.txt", io.Reader(file),
   uploadOpts)
if err != nil {
   panic(err)
}
fmt.Printf("New file uploaded with ID %s", objectID)

file, err := os.Open("path/to/file.txt")
if err != nil {
	panic(err)
}
uploadOpts := options.GridFSUpload().SetChunkSizeBytes(200000)
uploadStream, err := bucket.OpenUploadStream("file.txt", uploadOpts)
if err != nil {
	panic(err)
}
fileContent, err := io.ReadAll(file)
if err != nil {
	panic(err)
}
var bytes int
if bytes, err = uploadStream.Write(fileContent); err != nil {
	panic(err)
}
fmt.Printf("New file uploaded with %d bytes written", bytes)

파일 정보 검색

GridFS 버킷의 files 컬렉션에 저장된 파일 메타데이터를 조회할 수 있습니다. files 컬렉션의 각 문서에는 다음 정보가 포함되어 있습니다.

• 파일 ID

• 파일 길이

• 최대 청크 크기

• 업로드 날짜 및 시간

• 파일 이름

• 다른 정보를 저장할 수 있는 metadata 문서입니다.

파일 데이터를 조회하려면 GridFSBucket 인스턴스에서 Find() 메서드를 호출합니다. 특정 파일 문서만 일치시키려면 쿼리 필터를 Find()에 인수로 전달하면 됩니다.

다음 예에서는 files 컬렉션에서 length 값이 1500보다 큰 문서의 파일 이름과 길이를 조회합니다.

filter := bson.D{{"length", bson.D{{"$gt", 1500}}}}
cursor, err := bucket.Find(filter)
if err != nil {
   panic(err)
}
type gridfsFile struct {
   Name   string `bson:"filename"`
   Length int64  `bson:"length"`
}
var foundFiles []gridfsFile
if err = cursor.All(context.TODO(), &foundFiles); err != nil {
   panic(err)
}
for _, file := range foundFiles {
   fmt.Printf("filename: %s, length: %d\n", file.Name, file.Length)
}

파일 다운로드

다음 방법 중 하나를 사용하여 GridFS 파일을 다운로드할 수 있습니다.

• DownloadToStream() 메서드를 사용하여 파일을 출력 스트림에 다운로드합니다.

• OpenDownloadStream() 메서드를 사용하여 입력 스트림을 엽니다.

id, err := primitive.ObjectIDFromHex("62f7bd54a6e4452da13b3e88")
fileBuffer := bytes.NewBuffer(nil)
if _, err := bucket.DownloadToStream(id, fileBuffer); err != nil {
   panic(err)
}

id, err := primitive.ObjectIDFromHex("62f7bd54a6e4452da13b3e88")
downloadStream, err := bucket.OpenDownloadStream(id)
if err != nil {
   panic(err)
}
fileBytes := make([]byte, 1024)
if _, err := downloadStream.Read(fileBytes); err != nil {
   panic(err)
}

파일 이름 바꾸기

Rename() 메서드를 사용하여 버킷에 있는 GridFS 파일의 이름을 업데이트할 수 있습니다. 파일 ID 값과 새 filename 값을 인수로 Rename()에 전달합니다.

다음 예에서는 파일 이름을 "mongodbTutorial.zip"으로 변경합니다.

id, err := primitive.ObjectIDFromHex("62f7bd54a6e4452da13b3e88")
if err := bucket.Rename(id, "mongodbTutorial.zip"); err != nil {
    panic(err)
}

파일 삭제

Delete() 메서드를 사용하여 GridFS 버킷에서 파일을 제거할 수 있습니다. 파일 ID 값을 인수로 Delete()에 전달합니다.

다음은 파일을 삭제하는 예입니다.

id, err := primitive.ObjectIDFromHex("62f7bd54a6e4452da13b3e88")
if err := bucket.Delete(id); err != nil {
   panic(err)
}

GridFS 버킷 삭제

Drop() 메서드를 사용하여 GridFS 버킷을 삭제할 수 있습니다.

다음 코드 예시에서는 GridFS 버킷을 삭제합니다.

if err := bucket.Drop(); err != nil {
   panic(err)
}

API 문서

이 가이드에 설명된 메서드 또는 유형에 대해 자세히 알아보려면 다음 API 설명서를 참조하세요.

• NewBucket()

• OpenUploadStream()

• UploadFromStream()

• find()

• OpenDownloadStream()

• DownloadToStream()

• Rename()

• Delete()

• Drop()