본문으로 바로가기
본문으로 바로가기

mongodb Table Function

원격 MongoDB 서버에 저장된 데이터에 대해 SELECT 쿼리를 실행할 수 있도록 합니다.

구문​

mongodb(host:port, database, collection, user, password, structure[, options[, oid_columns]]);
mongodb(uri, collection, structure[, oid_columns]);
mongodb(named_collection_name[, <arg>=<value>...]);

Arguments​

ArgumentDescription
host:portMongoDB 서버 주소입니다.
database원격 데이터베이스 이름입니다.
collection원격 컬렉션 이름입니다.
userMongoDB 사용자입니다.
password사용자 비밀번호입니다.
structure이 FUNCTION이 반환하는 ClickHouse 테이블의 스키마입니다.
optionsMongoDB 연결 문자열 옵션입니다(선택적 매개변수).
oid_columnsWHERE 절에서 oid로 처리해야 하는 컬럼들의 쉼표로 구분된 목록입니다. 기본값은 _id입니다.
팁

MongoDB Atlas Cloud 서비스를 사용하는 경우 다음 옵션을 추가하십시오:

'connectTimeoutMS=10000&ssl=true&authSource=admin'

URI를 통해서도 연결할 수 있습니다:

mongodb(uri, collection, structure[, oid_columns])
ArgumentDescription
uri연결 문자열입니다.
collection원격 컬렉션 이름입니다.
structure이 FUNCTION이 반환하는 ClickHouse 테이블의 스키마입니다.
oid_columnsWHERE 절에서 oid로 처리해야 하는 컬럼의 쉼표로 구분된 목록입니다. 기본값은 _id입니다.
:::

인수는 이름이 지정된 컬렉션(named collection)을 사용해 전달할 수 있습니다:

mongodb(_named_collection_[, host][, port][, database][, collection][, user][, password][, structure][, options][, oid_columns])
-- or
mongodb(_named_collection_[, uri][, structure][, oid_columns])

반환 값​

원본 MongoDB 테이블과 동일한 컬럼을 갖는 테이블 객체입니다.

예시​

MongoDB 데이터베이스 test에 정의된 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 table function을 사용하여 컬렉션을 쿼리해 보겠습니다:

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:password@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:password@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'
)