Partilhar via


Copiar dados do HBase usando Azure Data Factory ou Synapse Analytics

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.

Importante

Este conector está na fase de Fim do Suporte. Recomenda-se migrar para o conector ODBC instalando um driver.

Este artigo descreve como usar a Atividade de Cópia num pipeline Azure Data Factory ou Synapse Analytics para copiar dados do HBase. 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.

Capacidades suportadas

Este conector HBase é suportado para os seguintes recursos:

Capacidades suportadas IR
Atividade de cópia (fonte/-) (1)
Atividade de Pesquisa (1)

(1) Runtime de integração Azure (2) Runtime de integração auto-hospedado

Para obter uma lista de armazenamentos de dados que são suportados como fontes/destinos pela atividade de cópia, consulte a tabela Armazenamentos de dados Suportados.

O serviço fornece um driver interno para habilitar a conectividade, portanto, você não precisa instalar manualmente nenhum driver usando esse conector.

Pré-requisitos

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 Azure Integration Runtime IPs à lista de permissõ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:

Criar um serviço vinculado ao HBase usando a interface do usuário

Use os passos seguintes para criar um serviço ligado ao HBase na interface do portal Azure.

  1. Navegue até ao separador Gerir no seu espaço de trabalho Azure Data Factory ou Synapse e selecione Serviços Ligados, depois clique em Novo:

  2. Procure HBase e selecione o conector HBase.

    Captura de ecrã do conector HBase.

  3. Configure os detalhes do serviço, teste a conexão e crie o novo serviço vinculado.

    Captura de tela da configuração do serviço vinculado para o HBase.

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 HBase.

Propriedades do serviço vinculado

As seguintes propriedades são suportadas para o serviço vinculado do HBase:

Propriedade Descrição Obrigatório
tipo A propriedade type deve ser definida como: HBase Sim
alojar O endereço IP ou nome do host do servidor HBase. (ou seja, [clustername].azurehdinsight.net, 192.168.222.160) Sim
porta A porta TCP que a instância do HBase usa para escutar conexões de cliente. O valor padrão é 9090. Se ligares ao Azure HDInsights, especifica a porta como 443. Não
httpPath A URL parcial correspondente ao servidor HBase, por exemplo /hbaserest0 , ao usar o cluster HDInsights. Não
tipo de autenticação O mecanismo de autenticação a ser usado para se conectar ao servidor HBase.
Os valores permitidos são: Anónimo, Básico
Sim
nome de utilizador O nome de usuário usado para se conectar à instância do HBase. Não
palavra-passe A senha correspondente ao nome de usuário. Marque este campo como um SecureString para o armazenar de forma segura, ou referencia um segredo guardado em Azure Key Vault. Não
habilitarSsl Especifica se as conexões com o servidor são criptografadas usando TLS. O valor predefinido é false. Não
trustedCertPath O caminho completo do arquivo .pem contendo certificados de CA confiáveis para verificar o servidor ao se conectar por TLS. Essa propriedade só pode ser definida ao usar TLS em IR auto-hospedado. O valor padrão é o arquivo cacerts.pem instalado com o IR. Não
permitirDesajusteNomeAnfitriãoCN Especifica se um nome de certificado TLS/SSL emitido pela CA deve corresponder ao nome do host do servidor ao se conectar por TLS. O valor predefinido é false. Não
permitirCertificadoDeServidorAutoAssinado Especifica se os certificados autoassinados do servidor devem ser permitidos. O valor predefinido é false. Não
ConecteVia O Integration Runtime para ser usado para se ligar ao armazenamento de dados. Saiba mais na seção Pré-requisitos . Só podes usar Azure Integration Runtime. Não

Nota

Se o seu cluster não suportar sessão persistente, como é o caso do HDInsight, adicione explicitamente o índice do nó no final da definição do caminho http. Por exemplo, especifique /hbaserest0 em vez de /hbaserest.

Exemplo para HDInsights HBase:

{
    "name": "HBaseLinkedService",
    "properties": {
        "type": "HBase",
        "typeProperties": {
            "host" : "<cluster name>.azurehdinsight.net",
            "port" : "443",
            "httpPath" : "/hbaserest0",
            "authenticationType" : "Basic",
            "username" : "<username>",
            "password": {
                "type": "SecureString",
                "value": "<password>"
            },
            "enableSsl" : true
        },
        "connectVia": {
            "referenceName": "<name of Integration Runtime>",
            "type": "IntegrationRuntimeReference"
        }
    }
}

Exemplo para HBase genérico:

{
    "name": "HBaseLinkedService",
    "properties": {
        "type": "HBase",
        "typeProperties": {
            "host" : "<host e.g. 192.168.222.160>",
            "port" : "<port>",
            "httpPath" : "<e.g. /gateway/sandbox/hbase/version>",
            "authenticationType" : "Basic",
            "username" : "<username>",
            "password": {
                "type": "SecureString",
                "value": "<password>"
            },
            "enableSsl" : true,
            "trustedCertPath" : "<trustedCertPath>",
            "allowHostNameCNMismatch" : true,
            "allowSelfSignedServerCert" : true
        },
        "connectVia": {
            "referenceName": "<name of Integration Runtime>",
            "type": "IntegrationRuntimeReference"
        }
    }
}

Propriedades do conjunto de dados

Para obter uma lista completa de seções e propriedades disponíveis para definir conjuntos de dados, consulte o artigo sobre conjuntos de dados. Esta seção fornece uma lista de propriedades suportadas pelo conjunto de dados do HBase.

Para copiar dados do HBase, defina a propriedade type do conjunto de dados como HBaseObject. As seguintes propriedades são suportadas:

Propriedade Descrição Obrigatório
tipo A propriedade type do conjunto de dados deve ser definida como: HBaseObject Sim
nomeDaTabela Nome da tabela. Não (se "consulta" for especificado na fonte da atividade)

Exemplo

{
    "name": "HBaseDataset",
    "properties": {
        "type": "HBaseObject",
        "typeProperties": {},
        "schema": [],
        "linkedServiceName": {
            "referenceName": "<HBase 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 do HBase.

HBaseSource como fonte

Para copiar dados do HBase, defina o tipo de origem na atividade de cópia como HBaseSource. As seguintes propriedades são suportadas na secção de origem da atividade de cópia.

Propriedade Descrição Obrigatório
tipo A propriedade tipo da fonte de atividade de cópia deve ser definida como: HBaseSource Sim
consulta Utilize uma consulta SQL personalizada para ler dados. Por exemplo: "SELECT * FROM MyTable". Não (se "tableName" estiver especificado no dataset)

Exemplo:

"activities":[
    {
        "name": "CopyFromHBase",
        "type": "Copy",
        "inputs": [
            {
                "referenceName": "<HBase input dataset name>",
                "type": "DatasetReference"
            }
        ],
        "outputs": [
            {
                "referenceName": "<output dataset name>",
                "type": "DatasetReference"
            }
        ],
        "typeProperties": {
            "source": {
                "type": "HBaseSource",
                "query": "SELECT * FROM MyTable"
            },
            "sink": {
                "type": "<sink type>"
            }
        }
    }
]

Propriedades da atividade de consulta

Para saber detalhes sobre as propriedades, consulte Atividade de Pesquisa.

Para obter uma lista de armazenamentos de dados suportados como fontes e destinos na atividade de cópia, consulte Armazenamentos de dados suportados.