FetchGridFS 2025.10.9.21 — MongoDB GridFS 파일 가져오기 프로세서

FetchGridFS 프로세서는 파일 이름이나 사용자 정의 쿼리로 GridFS 버킷에서 하나 이상의 파일을 가져와요.

출처: Snowflake 문서

본문

기능 — 일반 공개 (Generally Available)

Openflow Snowflake 배포는 AWS, Azure, GCP의 상용 리전에서 모든 계정에 제공돼요.

Openflow BYOC 배포는 AWS의 상용 리전에서 모든 계정에 제공돼요.

org.apache.nifi | nifi-mongodb-nar

파일 이름 또는 사용자 정의 쿼리로 GridFS 버킷에서 하나 이상의 파일을 가져와요.

REQUIRED

false

Property	Description
gridfs-bucket-name	파일이 저장될 GridFS 버킷이에요. 비워두면 MongoDB 클라이언트 드라이버가 사용하는 기본값 'fs'를 사용해요
gridfs-client-service	데이터베이스 연결에 사용할 MongoDB 클라이언트 서비스
gridfs-database-name	사용할 데이터베이스의 이름
gridfs-file-name	이 프로세서의 대상이 되는 버킷 내 파일의 이름
gridfs-query	GridFS에서 하나 이상의 파일을 가져오는 데 사용할 유효한 MongoDB 쿼리
mongo-operation-mode	이 옵션은 결과를 다운스트림 프로세서에 언제 사용할 수 있게 할지 제어해요. Stream Query Results가 활성화되면 입력 flowfile이 수신되어 쿼리를 시작하면 입력 flowfile에 대한 provenance가 추적되지 않아요. Stream Query Results 모드에서는 입력 flowfile의 원본 내용과 속성을 가진 새 flowfile을 failure 관계로 보내는 방식으로 오류가 처리돼요. 스트리밍은 MongoDB와 NiFi 사이에 안정적인 연결이 있을 때만 사용해야 해요
mongo-query-attribute	설정하면 쿼리가 출력 flowfile의 지정된 속성에 기록돼요

Name	Description
failure	flowfile 처리에 실패하면 이 관계로 이동해요
original	쿼리가 오류를 일으키지 않으면 원래 입력 flowfile이 이 관계로 이동해요
success	작업이 성공하면 flowfile이 이 관계로 전송돼요

Name	Description
gridfs.file.metadata	파일과 함께 저장된 사용자 지정 메타데이터가 있으면 이 속성에 연결돼요