ApsaraDB for HBase:Accès à l'API multilingue

Installation du compilateur Thrift

La plupart des langages permettent d'installer directement la bibliothèque Thrift via leur gestionnaire de packages. Téléchargez le compilateur uniquement si vous devez régénérer les fichiers de définition d'interface à partir de Hbase.thrift.

Gestionnaire de packages (recommandé) :

Installation manuelle du compilateur : Téléchargez le fichier thrift-0.12.0.tar.gz et suivez le guide d'installation de Thrift.

Génération du fichier de définition d'interface

1. Téléchargez le fichier de définition Thrift 2 pour ApsaraDB for HBase.

2. Extrayez le package du compilateur Thrift et exécutez la commande suivante depuis le répertoire extrait pour générer les liaisons spécifiques au langage :

   thrift --gen <language> Hbase.thrift

   Exemples :

   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()