GridFS.

GridFS 버킷 만들기

GridFS에서 파일을 저장하거나 조회하려면 버킷을 만들거나 MongoDB Database에서 기존 버킷에 대한 참조를 가져오면 됩니다. GridFSBucket 인스턴스를 생성하려면 다음 코드와 같이 Database 인스턴스에서 GridFSBucket() 메서드를 호출합니다.

db := client.Database("myDB")
bucket := db.GridFSBucket()

기본적으로 드라이버는 버킷의 이름을 fs로 설정합니다. 사용자 지정 이름으로 버킷을 생성하려면 다음 코드에 표시된 대로 BucketOptions 인스턴스에서 SetName() 메서드를 호출합니다.

db := client.Database("myDB")
bucketOpts := options.GridFSBucket().SetName("myCustomBucket")
bucket := db.GridFSBucket(bucketOpts)

파일 업로드

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

• UploadFromStream()입력 스트림에서 읽습니다.

• OpenUploadStream()출력 스트림에 씁니다.

두 업로드 프로세스 모두에서 인스턴스 만들어 구성 정보를 지정할 수 UploadOptions 있습니다. 전체 옵션 목록을 보려면 UploadOptions API 설명서를 참조하세요.

file, err := os.Open("home/documents/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)

New file uploaded with ID ...

file, err := os.Open("home/documents/file.txt")
if err != nil {
	panic(err)
}
// Defines options that specify configuration information for files
// uploaded to the bucket
uploadOpts := options.GridFSUpload().SetChunkSizeBytes(200000)
// Writes a file to an output stream
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)
//  Calls the Close() method to write file metadata
if err := uploadStream.Close(); err != nil {
	panic(err)
}

파일 정보 검색

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

• 파일 ID

• 파일 길이

• 최대 청크 크기

• 업로드 날짜 및 시간

• 파일 이름

• metadata 기타 정보를 저장하는 문서

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

다음 예에서는 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 문서를 참조하세요.

• GridFSBucket()

• OpenUploadStream()

• UploadFromStream()

• find()

• OpenDownloadStream()

• DownloadToStream()

• Rename()

• Delete()

• Drop()