ApsaraDB for HBase:Acesso à API em múltiplas linguagens

Instale o compilador Thrift

A maioria das linguagens permite instalar a biblioteca Thrift diretamente pelo gerenciador de pacotes. Baixe o compilador apenas se precisar regenerar os arquivos de definição de interface a partir do Hbase.thrift.

Gerenciador de pacotes (recomendado):

Instalação manual do compilador: Baixe o arquivo thrift-0.12.0.tar.gz e siga o guia de instalação do Thrift.

Gerar o arquivo de definição de interface

1. Baixe o arquivo de definição Thrift 2 para ApsaraDB for HBase.

2. Extraia o pacote do compilador Thrift e execute o comando abaixo no diretório extraído para gerar as bindings específicas da linguagem:

   thrift --gen <language> Hbase.thrift

   Exemplos:

   thrift --gen py Hbase.thrift
   thrift --gen cpp Hbase.thrift
   thrift --gen php Hbase.thrift

# -*- coding: utf-8 -*-
# Install the Thrift library: pip install thrift
from thrift.protocol import TBinaryProtocol
from thrift.transport import THttpClient

# Generated by: thrift --gen py Hbase.thrift
from hbase import THBaseService
from hbase.ttypes import (
    TColumnValue, TColumn, TTableName, TTableDescriptor,
    TColumnFamilyDescriptor, TNamespaceDescriptor,
    TGet, TPut, TScan
)

# Replace <host> with your cluster endpoint.
url = "http://<host>:9190"

# THttpClient is required — the HBase Thrift server uses HTTP transport,
# not the standard socket transport.
transport = THttpClient.THttpClient(url)

# Pass credentials as custom HTTP headers. Thrift 2 requires the username and password.
headers = {
    "ACCESSKEYID": "<your-username>",       # Cluster username
    "ACCESSSIGNATURE": "<your-password>",   # Cluster password
}
transport.setCustomHeaders(headers)

# TBinaryProtocolAccelerated uses a C extension for faster serialization
# when available, and falls back to the pure-Python implementation.
protocol = TBinaryProtocol.TBinaryProtocolAccelerated(transport)

# Create the HBase client using the configured protocol.
client = THBaseService.Client(protocol)

# Open the connection before making any calls.
transport.open()

# Your HBase operations go here.

# Close the transport when done to release the connection.
transport.close()