ApsaraDB for HBase:Akses API multi-bahasa

Prasyarat

Sebelum memulai, pastikan Anda telah memiliki:

• Titik akhir kluster Anda. Untuk mendapatkan titik akhir tersebut, lihat Ajukan titik akhir publik.

Cara kerja

ApsaraDB for HBase Performance-enhanced Edition menggunakan HTTP pada lapisan transport Thrift. Semua klien harus menggunakan THttpClient—bukan transport socket standar—untuk terhubung. Untuk Thrift 2, Anda harus menentukan nama pengguna dan kata sandi sebagai header HTTP kustom dalam instans THttpClient.

Thrift 1 vs. Thrift 2

Gunakan Thrift 2 untuk integrasi baru. Thrift 1 tidak mendukung autentikasi dan tidak cocok untuk kluster yang mengaktifkan ACL.

Siapkan Thrift

Inisialisasi client

Contoh berikut menggunakan Python. Terapkan pola yang sama untuk bahasa lain: buat THttpClient, tambahkan header autentikasi, bungkus dengan TBinaryProtocol, lalu berikan protokol tersebut ke THBaseService.Client.

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

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

# Ganti <host> dengan titik akhir kluster Anda.
url = "http://<host>:9190"

# THttpClient wajib digunakan — server Thrift HBase menggunakan transport HTTP,
# bukan transport socket standar.
transport = THttpClient.THttpClient(url)

# Berikan kredensial sebagai header HTTP kustom. Thrift 2 memerlukan username dan password.
headers = {
    "ACCESSKEYID": "<your-username>",       # Username kluster
    "ACCESSSIGNATURE": "<your-password>",   # Password kluster
}
transport.setCustomHeaders(headers)

# TBinaryProtocolAccelerated menggunakan ekstensi C untuk serialisasi lebih cepat
# jika tersedia, dan mundur ke implementasi murni Python jika tidak.
protocol = TBinaryProtocol.TBinaryProtocolAccelerated(transport)

# Buat client HBase menggunakan protokol yang telah dikonfigurasi.
client = THBaseService.Client(protocol)

# Buka koneksi sebelum melakukan panggilan apa pun.
transport.open()

# Operasi HBase Anda ditempatkan di sini.

# Tutup transport saat selesai untuk melepaskan koneksi.
transport.close()

Placeholders:

Kode contoh

Contoh klien lengkap yang dapat dijalankan untuk setiap bahasa tersedia di GitHub. Setiap repositori mencakup file definisi Thrift dan semua dependensi khusus bahasa.

Langkah selanjutnya

• Tutorial Apache Thrift — pelajari lebih lanjut tentang operasi Thrift di semua bahasa yang didukung.