Lindorm:Use a API do ApsaraDB for HBase com linguagens não Java para desenvolver aplicações

Para mais informações sobre como usar o pacote de instalação do Thrift, consulte a documentação oficial do Apache Thrift. Para acessar o mecanismo de tabela ampla do Lindorm via Thrift, siga estas etapas:

1. Execute o comando a seguir para gerar um arquivo IDL (Interface Definition Language) na linguagem desejada, usando o arquivo de definição Thrift2 do ApsaraDB for HBase:

   thrift --gen <language> Hbase.thrift

   Nota

   O espaço reservado language representa a linguagem de programação de destino, como python, php, cpp ou py.

   Exemplo de comando:

   thrift --gen py Hbase.thrift

2. Crie um cliente para acessar o mecanismo de tabela ampla do Lindorm.

   O servidor Thrift no Lindorm usa HTTP na camada de transporte. Portanto, o ThttpClient do Thrift é obrigatório ao criar o cliente. O método de criação varia conforme a linguagem. Se a Access Control List (ACL) estiver ativada, especifique o nome de usuário e a senha em dois cabeçalhos do ThttpClient para autenticação. Caso a ACL esteja desativada, essas credenciais serão dispensáveis. O Thrift permite chamar uma função específica da linguagem para definir cabeçalhos personalizados no ThttpClient. O exemplo a seguir usa Python. Execute os comandos abaixo para criar um cliente e conectar-se ao LindormTable:

    # -*- coding: utf-8  -*-
    # The following two modules are generated by running the 'pip install thrift' command.
    from thrift.protocol import TBinaryProtocol
    from thrift.transport import THttpClient
    # The following two modules are generated by running the 'thrift --gen py hbase.thrift' command.
    from hbase import THBaseService
    from hbase.ttypes import TColumnValue, TColumn, TTableName, TTableDescriptor, TColumnFamilyDescriptor, TNamespaceDescriptor, TGet, TPut, TScan
    # Configure the endpoint for the Lindorm wide table engine.
    url = "http://ld-bp17j28j2y7pm****-proxy-lindorm.lindorm.rds.aliyuncs.com:9190"
    transport = THttpClient.THttpClient(url)
    headers = {}
    # Set the username.
    headers["ACCESSKEYID"]="testuser";
    # Set the password that corresponds to the username.
    headers["ACCESSSIGNATURE"]="password"
    transport.setCustomHeaders(headers)
    protocol = TBinaryProtocol.TBinaryProtocolAccelerated(transport)
    client = THBaseService.Client(protocol)
    transport.open()
    # Close the connection after the operations are complete.
    transport.close()

Para obter exemplos completos em outras linguagens não Java, clique em um dos links a seguir para baixar o código-fonte correspondente no GitHub:

• Python

• Go

• C++

• node.js

• PHP