mongodb

リモートの MongoDB サーバーに保存されているデータに対して SELECT クエリを実行できます。

リモートの 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>...]);

​

引数

引数	説明
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])
-- または
mongodb(_named_collection_[, uri][, structure][, oid_columns])

​

戻り値

元のMongoDBテーブルと同じカラムを持つテーブルオブジェクトです。

​

例

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

​

関連

• MongoDB テーブルエンジン
• MongoDB を Dictionary ソースとして使う