Data Transmission Service:ApsaraDB for MongoDB レプリカセットインスタンスから Function Compute 関数へのデータ同期

DTS コンソール

1. DTS コンソール にログインします。DTS コンソール

2. 左側ナビゲーションウィンドウで、データ同期 をクリックします。

3. 画面左上隅で、同期タスクを実行するリージョンを選択します。

DMS コンソール

具体的なナビゲーション手順は、DMSコンソールモードとレイアウトによって異なります。「シンプルモード」および「DMSコンソールのレイアウトとスタイルをカスタマイズする」をご参照ください。

1. DMS コンソール にログインします。DMS コンソール

2. 上部ナビゲーションバーで、Data + AI にポインターを合わせ、DTS (DTS) > データ同期 を選択します。

3. データ同期タスク の右側にあるドロップダウンリストから、リージョンを選択します。

コレクションの作成

コレクションの削除

インデックスの作成

インデックスの削除

データの挿入

SQL ステートメント：

// 複数のレコードを一度に挿入
db.runCommand({insert: "user", documents: [{"name":"jack","age":20},{"name":"lili","age":20}]})

// 1 件ずつレコードを挿入
db.user.insert({"name":"jack","age":20})
db.user.insert({"name":"lili","age":20})

関数が受信するデータ：

{
  "Records": [
    {
      "data": [{"doc": "{\"_id\": {\"$oid\": \"64f9397f6e255f74d65a****\"}, \"name\": \"jack\", \"age\": 20}"}],
      "pkNames": ["_id"],
      "type": "INSERT",
      "es": 1694054783000,
      "database": "MongoDBTest",
      "id": 0,
      "isDdl": false,
      "table": "user",
      "ts": 1694054784427
    },
    {
      "data": [{"doc": "{\"_id\": {\"$oid\": \"64f9397f6e255f74d65a****\"}, \"name\": \"lili\", \"age\": 20}"}],
      "pkNames": ["_id"],
      "type": "INSERT",
      "es": 1694054783000,
      "database": "MongoDBTest",
      "id": 0,
      "isDdl": false,
      "table": "user",
      "ts": 1694054784428
    }
  ]
}

データの更新

SQL ステートメント：

db.user.update({"name":"jack"},{$set:{"age":30}})

関数が受信するデータ：

{
  "Records": [{
    "data": [{"doc": "{\"$set\": {\"age\": 30}}"}],
    "pkNames": ["_id"],
    "old": [{"doc": "{\"_id\": {\"$oid\": \"64f9397f6e255f74d65a****\"}}"}],
    "type": "UPDATE",
    "es": 1694054989000,
    "database": "MongoDBTest",
    "id": 0,
    "isDdl": false,
    "table": "user",
    "ts": 1694054990555
  }]
}

データの削除

SQL ステートメント：

db.user.remove({"name":"jack"})

関数が受信するデータ：

{
  "Records": [{
    "data": [{"doc": "{\"_id\": {\"$oid\": \"64f9397f6e255f74d65a****\"}}"}],
    "pkNames": ["_id"],
    "type": "DELETE",
    "es": 1694055452000,
    "database": "MongoDBTest",
    "id": 0,
    "isDdl": false,
    "table": "user",
    "ts": 1694055452852
  }]
}