コンテンツにスキップ

MongoDBコネクタ

MongoDBコネクタは、MongoDBコレクションにJSONドキュメントを書き込みます。

コネクタタイプ: MongoWriter

{
"type": "MongoWriter",
"config": {
"endpoint": "mongodb://root:password@localhost:27017/",
"database": "sensor_db",
"collection": "measurements"
}
}
  • endpoint: MongoDB接続文字列
  • database: データベース名
  • collection: コレクション名
mongodb://localhost:27017/
mongodb://username:password@localhost:27017/
mongodb+srv://username:password@cluster.mongodb.net/
mongodb://localhost:27017/?authSource=admin&retryWrites=true

入力ペイロード:

{
"temperature": 25.5,
"humidity": 60,
"timestamp": 1234567890
}

MongoDBドキュメントとして保存:

{
"_id": ObjectId("..."),
"temperature": 25.5,
"humidity": 60,
"timestamp": 1234567890
}

ユースケース:IoTデータストレージ

Section titled “ユースケース:IoTデータストレージ”
{
"type": "MongoWriter",
"config": {
"endpoint": "mongodb://mongo.local:27017/",
"database": "iot_platform",
"collection": "sensor_readings"
}
}
  1. 意味のあるデータベースとコレクション名を使用
  2. ドキュメントにタイムスタンプを追加
  3. 頻繁にクエリされるフィールドにインデックスを使用
  4. コレクションサイズを監視してアーカイブを実装
  • InfluxDB - 時系列代替
  • SQL - リレーショナルデータベース代替