mongodb テーブル関数

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

構文

mongodb(host:port, database, collection, user, password, structure[, options[, oid_columns]])

引数

引数	説明
`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 テーブルと同じ列を持つテーブルオブジェクトです。

例

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 テーブル関数を使ってコレクションにクエリしてみましょう。

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:[email protected]:27017/test?connectionTimeoutMS=10000',
    'my_collection',
    'log_type String, host String, command String'
)

構文​

引数​

返される値​

例​

関連項目​

構文

引数

返される値

例

関連項目