mongodb
mongodb
원격 MongoDB 서버에 저장된 데이터에 SELECT 쿼리를 수행할 수 있게 해주는 테이블 함수예요.
출처: 문서
본문
원격 MongoDB 서버에 저장된 데이터에 SELECT 쿼리를 수행할 수 있게 해줘요.
문법 (Syntax)
mongodb(host:port, database, collection, user, password, structure[, options[, oid_columns]]);
mongodb(uri, collection, structure[, oid_columns]);
mongodb(named_collection_name[, <arg>=<value>...]);
인자 (Arguments)
| 인자 | 설명 |
|---|---|
host:port |
MongoDB 서버 주소예요. |
database |
원격 데이터베이스 이름이에요. |
collection |
원격 컬렉션 이름이에요. |
user |
MongoDB 사용자예요. |
password |
사용자 비밀번호예요. |
structure |
이 함수가 반환하는 ClickHouse 테이블의 스키마예요. |
options |
MongoDB 연결 문자열 옵션이에요(선택 사항). |
oid_columns |
WHERE 절에서 oid로 취급해야 하는 컬럼들의 쉼표로 구분된 목록이에요. 기본은 _id예요. |
MongoDB Atlas 클라우드 제공을 사용 중이라면 이 옵션을 추가하세요:
'connectTimeoutMS=10000&ssl=true&authSource=admin'
URI로도 연결할 수 있어요:
mongodb(uri, collection, structure[, oid_columns])
| 인자 | 설명 |
|---|---|
uri |
연결 문자열이에요. |
collection |
원격 컬렉션 이름이에요. |
structure |
이 함수가 반환하는 ClickHouse 테이블의 스키마예요. |
oid_columns |
WHERE 절에서 oid로 취급해야 하는 컬럼들의 쉼표로 구분된 목록이에요. 기본은 _id예요. |
네임드 컬렉션을 사용해 인자를 전달할 수도 있어요:
mongodb(_named_collection_[, host][, port][, database][, collection][, user][, password][, structure][, options][, oid_columns])
-- or
mongodb(_named_collection_[, uri][, structure][, oid_columns])
반환값 (Returned value)
원래 MongoDB 테이블과 같은 컬럼을 가진 테이블 객체예요.
예시 (Examples)
test라는 MongoDB 데이터베이스에 my_collection이라는 컬렉션이 정의되어 있고, 몇 개의 문서를 삽입했다고 가정해볼게요:
db.createUser({user:"test_user",pwd:"password",roles:[{role:"readWrite",db:"test"}]})
db.createCollection("my_collection")
db.my_collection.insertOne(
{ log_type: "event", host: "120.5.33.9", command: "check-cpu-usage -w 75 -c 90" }
)
db.my_collection.insertOne(
{ log_type: "event", host: "120.5.33.4", command: "system-check"}
)
mongodb 테이블 함수로 컬렉션을 조회해볼게요:
SELECT * FROM mongodb(
'127.0.0.1:27017',
'test',
'my_collection',
'test_user',
'password',
'log_type String, host String, command String',
'connectTimeoutMS=10000'
)
또는:
SELECT * FROM mongodb(
'mongodb://test_user:***@127.0.0.1:27017/test?connectionTimeoutMS=10000',
'my_collection',
'log_type String, host String, command String'
)
또는:
CREATE NAMED COLLECTION mongo_creds AS
uri='mongodb://test_user:***@127.0.0.1:27017/test?connectionTimeoutMS=10000',
collection='default_collection';
SELECT * FROM mongodb(
mongo_creds,
collection = 'my_collection',
structure = 'log_type String, host String, command String'
)