Nota
O acesso a esta página requer autorização. Pode tentar iniciar sessão ou alterar os diretórios.
O acesso a esta página requer autorização. Pode tentar alterar os diretórios.
APLICA-SE A:
Azure Data Factory
Azure Synapse Analytics
Gorjeta
Data Factory em Microsoft Fabric é a próxima geração de Azure Data Factory, com uma arquitetura mais simples, IA incorporada e novas funcionalidades. Se és novo na integração de dados, começa pelo Fabric Data Factory. As cargas de trabalho existentes do ADF podem atualizar para o Fabric para aceder a novas capacidades em ciência de dados, análise em tempo real e relatórios.
Este artigo descreve como usar a Atividade de Cópia nos pipelines Azure Data Factory e Synapse Analytics para copiar dados de e para uma base de dados MongoDB. Ele se baseia no artigo de visão geral da atividade de cópia que apresenta uma visão geral da atividade de cópia.
Note
Este conector também está disponível no Data Factory na Microsoft Fabric. Para configurações e características específicas do Fabric, consulte a documentação do conector MongoDB para Fabric.
Importante
O novo conector MongoDB oferece suporte nativo aprimorado ao MongoDB. Se estiver a usar o conector MongoDB antigo na sua solução, suportado as-is apenas para compatibilidade retroativa, veja conector MongoDB (legacy). Pode usar este conector para copiar dados de e para um Azure DocumentDB (com compatibilidade com MongoDB).
Capacidades suportadas
Este conector MongoDB suporta as seguintes capacidades:
| Capacidades suportadas | IR |
|---|---|
| atividade Copy (fonte/sumidouro) | (1) (2) |
(1) Runtime de integração Azure (2) Runtime de integração auto-hospedado
Para uma lista de armazenamentos de dados suportados como fontes e sumidouros, consulte a tabela de armazenamentos de dados suportados .
Especificamente, este conector MongoDB suporta versões até 4.2. Se o seu trabalho requer versões mais recentes do que a 4.2, considere usar o MongoDB Atlas com o conector MongoDB Atlas, que fornece suporte e recursos mais abrangentes.
Pré-requisitos
Se o seu armazenamento de dados estiver localizado numa rede local, numa rede virtual Azure ou na Amazon Virtual Private Cloud, precisa de configurar um runtime de integração auto-hospedado para se ligar a ele.
Se o seu armazenamento de dados for um serviço de dados na cloud gerido, pode usar o Azure Integration Runtime. Se o acesso for restrito a IPs aprovados nas regras do firewall, pode adicionar IPs Azure Integration Runtime à lista de autorizações.
Também pode usar a funcionalidade managed virtual network integration runtime no Azure Data Factory para aceder à rede local sem instalar e configurar um runtime de integração auto-hospedado.
Para obter mais informações sobre os mecanismos de segurança de rede e as opções suportadas pelo Data Factory, consulte Estratégias de acesso a dados.
Começar
Para executar a atividade de cópia com um pipeline, você pode usar uma das seguintes ferramentas ou SDKs:
- Ferramenta Copiar dados
- Portal do Azure
- .NET SDK
- Python SDK
- Azure PowerShell
- API REST
- Modelo do Azure Resource Manager
Crie um serviço ligado ao MongoDB usando a interface
Use os passos seguintes para criar um serviço ligado ao MongoDB na interface do portal do Azure.
Navegue até ao separador Gerir no seu espaço de trabalho Azure Data Factory ou Synapse e selecione Serviços Ligados. Depois seleciona Novo:
Procure MongoDB e selecione o conector MongoDB.
Configure os detalhes do serviço, teste a conexão e crie o novo serviço vinculado.
Detalhes de configuração do conector
As seções a seguir fornecem detalhes sobre as propriedades usadas para definir entidades do Data Factory específicas para o conector MongoDB.
Propriedades do serviço vinculado
A tabela seguinte lista as propriedades suportadas para um serviço ligado ao MongoDB:
| Propriedade | Descrição | Obrigatório |
|---|---|---|
| tipo | Defina a propriedade de tipo para: MongoDbV2 | Sim |
| connectionString | Especifique a cadeia de ligação do MongoDB, como mongodb://[username:password@]host[:port][/[database][?options]]. Para mais detalhes, consulte o manual do MongoDB sobre cadeia de ligação.Também pode colocar uma cadeia de conexão no Azure Key Vault. Para mais detalhes, consulte Armazenar credenciais no Azure Key Vault. |
Sim |
| base de dados | Nome do banco de dados que você deseja acessar. | Sim |
| conectarVia | O Integration Runtime a ser usado para se conectar ao armazenamento de dados. Para saber mais, consulte a seção Pré-requisitos . Se não especificares esta propriedade, usa-se a Azure Integration Runtime padrão. | Não |
Exemplo:
{
"name": "MongoDBLinkedService",
"properties": {
"type": "MongoDbV2",
"typeProperties": {
"connectionString": "mongodb://[username:password@]host[:port][/[database][?options]]",
"database": "myDatabase"
},
"connectVia": {
"referenceName": "<name of Integration Runtime>",
"type": "IntegrationRuntimeReference"
}
}
}
Propriedades do conjunto de dados
Para uma lista completa de secções e propriedades que pode usar para definir conjuntos de dados, consulte Conjuntos de dados e serviços ligados. A tabela seguinte lista as propriedades suportadas para um conjunto de dados MongoDB:
| Propriedade | Descrição | Obrigatório |
|---|---|---|
| tipo | Defina a propriedade de tipo do conjunto de dados para: MongoDbV2Collection | Sim |
| nome da coleção | Nome da coleção no banco de dados MongoDB. | Sim |
Exemplo:
{
"name": "MongoDbDataset",
"properties": {
"type": "MongoDbV2Collection",
"typeProperties": {
"collectionName": "<Collection name>"
},
"schema": [],
"linkedServiceName": {
"referenceName": "<MongoDB linked service name>",
"type": "LinkedServiceReference"
}
}
}
Propriedades da atividade de cópia
Para obter uma lista completa de seções e propriedades disponíveis para definir atividades, consulte o artigo Pipelines . Esta seção fornece uma lista de propriedades suportadas pela fonte e pelo coletor do MongoDB.
MongoDB como fonte
A secção de origem da atividade de cópia suporta as seguintes propriedades:
| Propriedade | Descrição | Obrigatório |
|---|---|---|
| tipo | Defina a propriedade de tipo da fonte da atividade de cópia para: MongoDbV2Source | Sim |
| filtro | Especifica o filtro de seleção usando operadores de consulta. Para retornar todos os documentos de uma coleção, omita esse parâmetro ou passe um documento vazio ({}). | Não |
| cursorMethods.project | Especifica os campos a serem retornados nos documentos para projeção. Para retornar todos os campos nos documentos correspondentes, omita esse parâmetro. | Não |
| cursorMethods.sort | Especifica a ordem na qual a consulta retorna documentos correspondentes. Consulte cursor.sort(). | Não |
| cursorMethods.limit | Especifica o número máximo de documentos retornados pelo servidor. Consulte cursor.limit(). | Não |
| cursorMethods.skip | Especifica o número de documentos a serem ignorados e de onde o MongoDB começa a retornar resultados. Consulte cursor.skip(). | Não |
| batchSize | Especifica o número de documentos a serem retornados em cada lote da resposta da instância do MongoDB. Na maioria dos casos, modificar o tamanho do lote não afeta o utilizador nem a aplicação. O Azure Cosmos DB limita que cada lote não pode exceder 40 MB de tamanho, que é a soma do tamanho do número de documentos do batchSize, por isso diminui este valor se o tamanho do teu documento for grande. | Não (o padrão é 100) |
Gorjeta
O serviço suporta o consumo de documento BSON no modo estrito. Garante que a tua consulta de filtro está em modo Estrito em vez de modo Shell. Para mais informações, consulte o manual do MongoDB.
Exemplo:
"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 como pia
A secção do sumidouro Copy Activity suporta as seguintes propriedades:
| Propriedade | Descrição | Obrigatório |
|---|---|---|
| tipo | Defina a propriedade type do destino da atividade de cópia como MongoDbV2Sink. | Sim |
| writeBehavior | Descreve como gravar dados no MongoDB. Valores permitidos: inserir e upsert. O comportamento do upsert é substituir o documento se já existir um documento com o mesmo _id , caso contrário, insira o documento.Nota: O serviço gera automaticamente um _id para um documento se um _id não for especificado no documento original ou por mapeamento de coluna. Isso significa que você deve garantir que, para que o upsert funcione conforme o esperado, seu documento tenha um ID. |
Não (o padrão é inserir) |
| writeBatchSize | A propriedade writeBatchSize controla o número de documentos a escrever em cada lote. Para melhorar o desempenho, tente aumentar o valor. Se o tamanho do seu documento for grande, tente diminuir o valor. | Não (o padrão é 10.000) |
| writeBatchTimeout | O tempo de espera para que a operação de inserção de lote termine antes que atinja o tempo limite. O valor permitido é intervalo de tempo. | Não (o padrão é 00:30:00 - 30 minutos) |
Gorjeta
Para importar documentos JSON as-is, consulte a secção Importar ou exportar documentos JSON . Para copiar a partir de dados em forma de tabular, veja Mapeamento de esquemas.
Exemplo
"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"
}
}
}
]
Importar e exportar documentos JSON
Use este conector MongoDB de forma muito fácil:
- Copie documentos entre duas coleções do MongoDB no estado em que se encontram.
- Importar documentos JSON de várias fontes para o MongoDB, incluindo do Azure Cosmos DB, Azure Blob storage, Azure Data Lake Store e outros armazenamentos baseados em ficheiros suportados.
- Exporte documentos JSON de uma coleção MongoDB para vários repositórios baseados em arquivos.
Para obter essa cópia independente de esquema, ignore a seção "estrutura" (também chamada de esquema) no conjunto de dados e efetue o mapa de esquema na atividade de cópia.
Mapeamento de tipo de dados para MongoDB
Quando copia dados do MongoDB, o serviço utiliza os seguintes mapeamentos dos tipos de dados do MongoDB para os tipos de dados intermédios. Para mais informações sobre como a atividade de cópia mapeia o esquema de origem e o tipo de dados para o sumidouro, veja Mapeamentos de esquema e tipos de dados.
| Tipo de dados MongoDB | Tipo de dados de serviço provisório |
|---|---|
| Date | Int64 |
| IdentificadorDoObjeto | String |
| Decimal128 | String |
| Carimbo de data/hora | Os 32 bits mais significativos -> Int64 Os 32 bits menos significativos -> Int64 |
| String | String |
| Double | String |
| Int32 | Int64 |
| Int64 | Int64 |
| booleano | booleano |
| Null | Null |
| JavaScript | String |
| Expressão regular | String |
| Chave mínima | Int64 |
| Tecla máxima | Int64 |
| Binary | String |
Ciclo de vida e atualização do conector MongoDB
A tabela a seguir mostra o estágio de liberação e os logs de alteração para diferentes versões do conector MongoDB:
| Versão | Fase de lançamento | Registo de alterações |
|---|---|---|
| MongoDB (legado) | Removed | Não aplicável. |
| MongoDB | Versão GA disponível | • Suporte apenas as consultas equivalentes do MongoDB. • Double é interpretado como tipo de dados String. |
Atualizar o serviço vinculado do MongoDB
Crie um novo serviço vinculado do MongoDB e configure-o consultando as propriedades do serviço vinculado.
Conteúdos relacionados
Para obter uma lista de armazenamentos de dados suportados como fontes e coletores pela atividade de cópia, consulte Armazenamentos de dados suportados.