全部產品
Search
文件中心

Lindorm:基於HBase非Java API的應用開發

更新時間:Jul 06, 2024

Lindorm寬表引擎支援通過HBase非Java(例如C++、Python和Go等)API進行訪問,本文介紹具體的訪問操作。

準備工作

訪問Lindorm寬表引擎(以Python語言為例)

Thrift安裝包的使用請參見Apache Thrift官方文檔,通過Thrift訪問Lindorm寬表引擎的步驟如下:

  1. 使用HBase Thrift2定義檔案來產生對應語言的介面檔案。 命令語句如下:

    thrift --gen <language> Hbase.thrift
    說明

    language為目標語言,例如:python、php、cpp、py等。

    語句樣本:

    thrift --gen python Hbase.thrift
  2. 構造用戶端訪問Lindorm寬表引擎。

    Lindorm中Thrift伺服器端的transport層使用的是HTTP,因此在構造用戶端時,需要thrift中的ThttpClient(各個語言都有相應實現)。並且在ACL開啟的情況下,需要在ThttpClient上加上兩個header來向伺服器傳輸使用者名稱和密碼進行認證(如果關閉ACL則不需要)。Thrift在每個語言實現的ThttpClient都有加定製header的函數。以Python語言為例,使用以下語句構造用戶端並訪問Lindorm寬表引擎。

     # -*- coding: utf-8  -*-
     # 以下兩個模組通過執行pip install thrift 語句產生
     from thrift.protocol import TBinaryProtocol
     from thrift.transport import THttpClient
    
     # 以下兩個模組通過執行thrift --gen py hbase.thrift 語句產生
     from hbase import THBaseService
     from hbase.ttypes import TColumnValue, TColumn, TTableName, TTableDescriptor, TColumnFamilyDescriptor, TNamespaceDescriptor, TGet, TPut, TScan
    
     # 配置Lindorm寬表引擎的串連地址
     url = "http://ld-bp17j28j2y7pm****-proxy-lindorm.lindorm.rds.aliyuncs.com:9190"
     transport = THttpClient.THttpClient(url)
     headers = {}
     # 設定使用者名稱
     headers["ACCESSKEYID"]="testuser";
     # 設定使用者名稱對應的密碼
     headers["ACCESSSIGNATURE"]="password"
     transport.setCustomHeaders(headers)
     protocol = TBinaryProtocol.TBinaryProtocolAccelerated(transport)
     client = THBaseService.Client(protocol)
     transport.open()
     # 具體操作後,執行關閉串連操作
     transport.close()

相關程式碼範例

其他非Java語言的完整程式碼範例請直接下載Github相應語言的程式碼範例,下載連結如下所示。