Copia dati da o verso MongoDB utilizzando Azure Data Factory o Synapse Analytics

APPLICABILE A: Azure Data Factory Azure Synapse Analytics

Questo articolo spiega come utilizzare l'attività di copia in Azure Data Factory e Synapse Analytics per copiare dati da e verso un database MongoDB. Si basa sull'articolo di panoramica dell'attività di copia che presenta una panoramica generale sull'attività di copia.

Funzionalità supportate

Questo connettore MongoDB supporta le seguenti funzionalità:

① Azure Integration Runtime ② Runtime di integrazione self-hosted

Per un elenco dei dati store supportati come source e sink, consulta la tabella Supported data stores .

In particolare, questo connettore MongoDB supporta le versioni fino alla 4.2. Se il lavoro richiede versioni più recenti della 4.2, considerare l'uso di MongoDB Atlas con il connettore MongoDB Atlas, che offre funzionalità e supporto più completi.

Prerequisiti

Se l'archivio dati si trova all'interno di una rete locale, di una rete virtuale Azure o di Amazon Virtual Private Cloud, è necessario configurare un runtime di integrazione self-hosted per connettersi.

Se l'archivio dati è un servizio dati cloud gestito, è possibile usare il Azure Integration Runtime. Se l'accesso è limitato agli indirizzi IP approvati nelle regole del firewall, è possibile aggiungere Azure Integration Runtime IP all'elenco elementi consentiti.

È anche possibile usare la funzionalità managed virtual network integration runtime in Azure Data Factory per accedere alla rete locale senza installare e configurare un runtime di integrazione self-hosted.

Per altre informazioni sui meccanismi di sicurezza di rete e sulle opzioni supportate da Data Factory, vedere strategie di accesso ai dati.

Introduzione

Per eseguire l'attività di copia con una pipeline, è possibile usare uno degli strumenti o degli SDK seguenti:

• Strumento Copia Dati
• portale Azure
• .NET SDK
• PYTHON SDK
• Azure PowerShell
• API REST
• modello Azure Resource Manager

Crea un servizio collegato a MongoDB usando l'interfaccia utente

Usare la procedura seguente per creare un servizio collegato a MongoDB nell'interfaccia utente del portale di Azure.

1. Sfoglia la scheda Gestisci nel tuo spazio di lavoro Azure Data Factory o Synapse e seleziona Servizi Collegati. Poi seleziona Nuovo:

   • Azure Data Factory
   • Azure Synapse

   

2. Cercare MongoDB e selezionare il connettore MongoDB.

   

3. Configurare i dettagli del servizio, testare la connessione e creare il nuovo servizio collegato.

   

Dettagli di configurazione del connettore

Le sezioni seguenti riportano informazioni dettagliate sulle proprietà che vengono usate per definire entità di data factory specifiche per il connettore MongoDB.

Proprietà del servizio collegato

La seguente tabella elenca le proprietà supportate per un servizio collegato a MongoDB:

È anche possibile inserire un stringa di connessione in Azure Key Vault. Per maggiori dettagli, consulta Archivia credenziali in Azure Key Vault. |Sì | | database | Nome del database a cui vuoi accedere. | Sì | | connectVia | L'Integration Runtime da utilizzare per connettersi allo store dati. Per altre informazioni, vedere la sezione Prerequisiti. Se non specifichi questa proprietà, viene usato il Azure Integration Runtime predefinito. |No |

Esempio:

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

Proprietà del set di dati

Per un elenco completo di sezioni e proprietà che puoi utilizzare per definire dataset, consulta Dataset e servizi collegati. La tabella seguente elenca le proprietà supportate per un dataset MongoDB:

Esempio:

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

Proprietà dell'attività di copia

Per un elenco completo delle sezioni e delle proprietà disponibili per la definizione delle attività, vedere l'articolo sulle pipeline. Questa sezione fornisce un elenco delle proprietà supportate dall'origine e dal sink MongoDB.

MongoDB come origine

La sezione sorgente dell'attività di copia supporta le seguenti proprietà:

Esempio:

"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 come sink

La sezione Copy Activity supporta le seguenti proprietà:

Esempio

"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"
            }
        }
    }
]

Importare ed esportare documenti JSON

Usa questo connettore MongoDB per facilità:

• Copiare i documenti tra due raccolte MongoDB così come sono.
• Importare documenti JSON da varie origini in MongoDB, tra cui Azure Cosmos DB, Azure Blob Storage, Azure Data Lake Store e altre memorie basate su file supportate.
• Esportare documenti JSON da una raccolta MongoDB in diversi archivi basati su file.

Per ottenere una copia priva di schema, ignorare la sezione "structure" (chiamata anche schema) nel set di dati e il mapping dello schema nell'attività di copia.

Mapping del tipo di dati per MongoDB

Quando copi dati da MongoDB, il servizio utilizza le seguenti mappature dai tipi di dati MongoDB ai tipi di dati intermedi. Per maggiori informazioni su come l'attività di copia mappa lo schema sorgente e il tipo di dato al sink, vedi Schema e mappature di tipo di dati.

Ciclo di vita e aggiornamento del connettore MongoDB

La tabella seguente illustra la fase di rilascio e i log delle modifiche per versioni diverse del connettore MongoDB:

• Legge anche come tipo di dato Stringa. |

Aggiornare il servizio collegato MongoDB

Creare un nuovo servizio collegato MongoDB e configurarlo facendo riferimento alle Proprietà del servizio collegato.

Contenuti correlati

Per un elenco degli archivi dati supportati come origini e sink dall'attività Copy, vedere Archivi dati supportati.