동기화 필터링

필터 구문

start API 엔드포인트는 필터링된 동기화를 구성하는 두 개의 필드인 includeNamespaces 및 excludeNamespaces를 허용합니다. 각 필드는 동기화에서 포함하거나 제외할 데이터베이스와 컬렉션을 지정하는 필터 배열을 사용합니다.

필터의 구문은 다음과 같습니다.

"includeNamespaces": [
    {
       "database": "<database-name>",
       "collections": [
          "<collection-name>"
       ]
       "databaseRegex": {
          "pattern": "<regex-pattern>",
          "options": "<options>"
       },
       "collectionsRegex": {
          "pattern": "<regex-pattern>",
          "options": "<options>"
       }
    }
 ],
 "excludeNamespaces": [
    {
       "database": "<database-name>",
       "collections": [
          "<collection-name>"
       ]
       "databaseRegex": {
          "pattern": "<regex-pattern>",
          "options": "<options>"
       },
       "collectionsRegex": {
          "pattern": "<regex-pattern>",
          "options": "<options>"
       }
    }
 ]

필터에는 database 필드 또는 databaseRegex 필드가 포함되어야 합니다.

특정 컬렉션과 일치하는 필터가 필요한 경우 collections 배열을 사용하여 컬렉션을 개별적으로 지정하거나 collectionsRegex 필드를 사용하여 정규식을 정의할 수 있습니다.

필터 구성

"includeNamespaces": [
   {
      "database": "sales",
      "collectionsRegex": {
         "pattern": "^accounts_.+?$",
         "options": "ms"
      }
],
"excludeNamespaces": [
    {
        "database": "sales",
        "collections": [
            "accounts_old"
        ]
    }
]

curl -X POST "http://localhost:27182/api/v1/start" --data '
   {
      "source": "cluster0",
      "destination": "cluster1",
      "includeNamespaces": [
         {
             "database": "sales",
             "collectionsRegex": {
                "pattern": "^accounts_.+$",
                "options": "i"
             }
         }, {
            "database": "marketing"
         }
      ]
   } '

예시 구성은 필터로 mongosync 시작을 참조하세요.

기존 필터 교체

기존 필터는 업데이트할 수 없습니다. 진행 중인 동기화 프로세스를 중지하고 대상 클러스터를 준비한 다음 새 필터로 mongosync를 다시 시작해야 합니다.

mongosync에서 원래 필터를 실행하면 사용자의 데이터('사용자 데이터베이스')와 mongosync_reserved_for_internal_use 시스템 데이터베이스를 포함하는 데이터베이스가 대상 클러스터에 생성됩니다. 새 필터로 mongosync를 다시 시작하기 전에 해당 데이터베이스를 제거해야 합니다.

새 필터를 위한 대상 클러스터를 준비하려면 다음 단계를 따르세요.

컬렉션 추가 및 이름 바꾸기

몇 가지 제한 사항이 있지만 필터링된 동기화 중에 컬렉션을 추가 또는 rename a collection할 수 있습니다.

mapReduce 및 $out을 사용한 필터링

필터링과 함께 $out 집계 단계 또는 mapReduce 명령(컬렉션을 생성하거나 대체하도록 설정된 경우)을 사용하려면 지정된 컬렉션뿐만 아니라 전체 데이터베이스를 필터링해야 합니다.

예를 들어 이 집계 파이프라인을 생각해 보세요.

use library
db.books.aggregate( [
   { $group : { _id : "$author", titles: { $push: "$title" } } },
   { $out : "authors" }
] )

$out 단계에서는 library 데이터베이스에 authors 컬렉션을 생성합니다. authors 컬렉션을 동기화하려면 필터에 전체 library 데이터베이스를 지정해야 합니다. authors 컬렉션만 지정하는 경우 필터가 작동하지 않습니다.

이 필터는 다음과 같이 작동합니다.

"includeNamespaces": [
  {
    "database": "library"
  }
]

이 필터는 작동하지 않습니다.

"includeNamespaces": [
  {
    "database": "library",
    "collections": [ "authors", "books" ]  // DOES NOT WORK WITH $OUT
  }
]

제한 사항

• 역동기화에서는 필터링이 지원되지 않습니다.

• 시작하기 전에 대상 클러스터에 사용자 데이터가 포함되어 있지 않아야 합니다.

• 시작하기 전에 대상 클러스터에 mongosync_reserved_for_internal_use 시스템 데이터베이스가 포함되어 있지 않아야 합니다.

• 사용 중인 필터는 수정할 수 없습니다. 새 필터를 만들려면 기존 필터 대체하기를 참조하세요.

• 컬렉션 이름은 특정 상황에서만 변경할 수 있습니다. 자세한 내용은 컬렉션 추가 및 이름 바꾸기를 참조하세요.

• 필터에 보기가 포함되어 있지만 기본 컬렉션은 포함되지 않은 경우 보기 메타데이터만 대상 클러스터에 동기화됩니다. 보기 문서를 포함하려면 기본 컬렉션도 동기화해야 합니다.

• 필터에 시스템 컬렉션이나 시스템 데이터베이스를 지정할 수 없습니다.

• 필터링과 함께 $out 집계 단계 또는 mapReduce 명령(컬렉션을 만들거나 대체하도록 설정된 경우)을 사용하려면 전체 데이터베이스를 사용하도록 필터를 구성해야 합니다. 필터를 데이터베이스 내의 컬렉션으로 제한할 수 없습니다.

  자세한 내용은 mapReduce 및 $out로 필터링하기를 참조하세요.

예시

"includeNamespaces" : [
      {
          "database" : "sales",
          "collections": [ "EMEA", "APAC" ]
      },
      {
          "database" : "marketing"
      }
   ]

{
   "source": "cluster0",
   "destination": "cluster1",
   "includeNamespaces":
      [
         { "database" : "students", "collections": ["undergrad", "graduate", "adjuncts"] },
         { "database" : "staff" }
      ]
}

// This code works
use admin
db.runCommand( { renameCollection: "staff.employees", to: "staff.salaried" } )

// This code works
use admin
db.runCommand( { renameCollection: "students.graduate", to: "students.adjuncts" } )

// This code produces an error and mongosync stops syncing
use admin
db.runCommand( { renameCollection: "students.graduate", to: "students.notAFilteredCollection" } )

use admin
db.runCommand( { renameCollection: "staff.employees", to: "staff.onPayroll" } )