Перейти к основному содержанию
Перейти к основному содержанию

Табличная функция MongoDB

Позволяет выполнять SELECT-запросы к данным, хранящимся на удалённом сервере MongoDB.

Синтаксис​

mongodb(хост:порт, база_данных, коллекция, пользователь, пароль, структура[, опции[, oid_столбцы]])

Аргументы​

АргументОписание
host:portАдрес сервера MongoDB.
databaseИмя удалённой базы данных.
collectionИмя удалённой коллекции.
userПользователь MongoDB.
passwordПароль пользователя.
structureСхема таблицы ClickHouse, возвращаемой этой функцией.
optionsПараметры строки подключения MongoDB (необязательный параметр).
oid_columnsСписок столбцов, разделённых запятыми, которые следует трактовать как oid в предложении WHERE. По умолчанию _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.

Примеры​

Предположим, у нас есть коллекция my_collection в базе данных MongoDB test, и мы вставляем в неё пару документов:

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:password@127.0.0.1:27017/test?connectionTimeoutMS=10000',
    'my_collection',
    'log_type String, host String, command String'
)