使用 Azure Data Factory 或 Synapse Analytics 從 MongoDB 複製資料

適用於： Azure Data Factory Azure Synapse Analytics

本文說明如何在 Azure Data Factory 與 Synapse Analytics 的管線中使用複製活動，將資料從 MongoDB 資料庫複製或複製到資料庫。 本文是根據複製活動概觀一文，該文提供複製活動的一般概觀。

支援的功能

此 MongoDB 連接器支援以下功能：

（1） Azure 整合執行時 （2） 自架整合執行時

關於支援作為來源與匯的資料儲存清單，請參閱 支援的資料儲存 表。

具體而言，這個 MongoDB 連接器所支援的版本最高可達 4.2 版。 如果您的工作需要比 4.2 更新的版本，請考慮搭配 MongoDB Atlas 連接器使用 MongoDB Atlas，以提供更完整的支援和功能。

先決條件

如果你的資料儲存位於本地網路、Azure虛擬網路或亞馬遜虛擬私人雲中，你需要配置一個自架整合執行時來連接它。

如果你的資料儲存是雲端管理型資料服務，你可以使用Azure Integration Runtime。 如果存取權限限制在防火牆規則中核准的 IP，你可以將 Azure Integration Runtime IPs 加入允許清單。

你也可以在 Azure Data Factory 中使用 managed 虛擬網路整合執行時功能，無需安裝和設定自架整合執行環境即可存取本地網路。

如需 Data Factory 支援的網路安全性機制和選項的詳細資訊，請參閱資料存取策略。

開始使用

若要使用管線執行複製活動，您可以使用下列其中一個工具或 SDK：

• 複製資料工具
• Azure portal
• .NET SDK
• Python SDK
• Azure PowerShell
• REST API
• Azure Resource Manager 模板

透過使用者介面建立與 MongoDB 連結的服務

請依照以下步驟在 Azure 入口網站介面中建立與 MongoDB 的連結服務。

1. 請瀏覽 Azure Data Factory 或 Synapse 工作區的「管理」標籤，選擇連結服務。 然後選擇新：

   • Azure Data Factory
   • Azure Synapse

   

2. 搜尋 MongoDB，然後選取 MongoDB 連接器。

   

3. 設定服務詳細資料，測試連線，然後建立新的連結服務。

   

連接器設定詳細資料

下列各節提供屬性的相關詳細資料，這些屬性是用來定義 MongoDB 連接器專屬的 Data Factory 實體。

連結服務屬性

下表列出了 MongoDB 連結服務所支援的屬性：

範例︰

{
    "name": "MongoDBLinkedService",
    "properties": {
        "type": "MongoDbV2",
        "typeProperties": {
            "connectionString": "mongodb://[username:password@]host[:port][/[database][?options]]",
            "database": "myDatabase"
        },
        "connectVia": {
            "referenceName": "<name of Integration Runtime>",
            "type": "IntegrationRuntimeReference"
        }
    }
}

資料集屬性

如需完整區段與屬性清單，請參見 資料集與連結服務。 下表列出 MongoDB 資料集所支援的屬性：

範例︰

{
    "name": "MongoDbDataset",
    "properties": {
        "type": "MongoDbV2Collection",
        "typeProperties": {
            "collectionName": "<Collection name>"
        },
        "schema": [],
        "linkedServiceName": {
            "referenceName": "<MongoDB linked service name>",
            "type": "LinkedServiceReference"
        }
    }
}

複製活動屬性

如需可用來定義活動的區段和屬性完整清單，請參閱管線一文。 本節提供 MongoDB 來源和接收器所支援的屬性清單。

MongoDB 作為來源

複製活動的 來源 區段支援下列屬性：

範例︰

"activities":[
    {
        "name": "CopyFromMongoDB",
        "type": "Copy",
        "inputs": [
            {
                "referenceName": "<MongoDB input dataset name>",
                "type": "DatasetReference"
            }
        ],
        "outputs": [
            {
                "referenceName": "<output dataset name>",
                "type": "DatasetReference"
            }
        ],
        "typeProperties": {
            "source": {
                "type": "MongoDbV2Source",
                "filter": "{datetimeData: {$gte: ISODate(\"2018-12-11T00:00:00.000Z\"),$lt: ISODate(\"2018-12-12T00:00:00.000Z\")}, _id: ObjectId(\"5acd7c3d0000000000000000\") }",
                "cursorMethods": {
                    "project": "{ _id : 1, name : 1, age: 1, datetimeData: 1 }",
                    "sort": "{ age : 1 }",
                    "skip": 3,
                    "limit": 3
                }
            },
            "sink": {
                "type": "<sink type>"
            }
        }
    }
]

MongoDB 做為接收器

複製活動接收器區段支援下列屬性：

範例

"activities":[
    {
        "name": "CopyToMongoDB",
        "type": "Copy",
        "inputs": [
            {
                "referenceName": "<input dataset name>",
                "type": "DatasetReference"
            }
        ],
        "outputs": [
            {
                "referenceName": "<Document DB output dataset name>",
                "type": "DatasetReference"
            }
        ],
        "typeProperties": {
            "source": {
                "type": "<source type>"
            },
            "sink": {
                "type": "MongoDbV2Sink",
                "writeBehavior": "upsert"
            }
        }
    }
]

匯入和匯出 JSON 文件

使用這個 MongoDB 連接器即可輕鬆：

• 在兩個 MongoDB 集合之間依原樣複製文件。
• 從各種來源匯入 JSON 文件到 MongoDB，包括 Azure Cosmos DB、Azure Blob 儲存、Azure Data Lake Store 及其他支援的檔案式儲存。
• 將 JSON 文件從 MongoDB 集合匯出至各種檔案型存放區。

若要完成這種跨平台結構描述的複製，請跳過資料集中的「結構」(也稱為「結構描述」) 區段，以及複製活動中的結構描述對應。

MongoDB 的資料類型對應

當你從 MongoDB 複製資料時，服務會使用以下從 MongoDB 資料型別到臨時資料型別的映射。 如需進一步瞭解複製活動如何將來源結構描述和資料型態對應到接收端，請參閱 結構描述和資料型態對應。

MongoDB 連接器生命週期和升級

下表顯示不同 MongoDB 連接器版本的發行階段和變更記錄：

升級 MongoDB 連結服務

建立新的 MongoDB 連結服務，並藉由參考連結服務屬性加以設定。

相關內容

如需複製活動支援作為來源和接收器的資料存放區清單，請參閱支援的資料存放區。