database/hbase

说明

Hbase Client，进行封装加入了链路追踪和统计。

配置

需要指定hbase集群的zookeeper地址。

  1. config := &hbase.Config{Zookeeper: &hbase.ZKConfig{Addrs: []string{"localhost"}}}
  2. client := hbase.NewClient(config)

使用方式

  1. package main
  3. import (
  4.     "context"
  5.     "fmt"
  7.     "github.com/go-kratos/kratos/pkg/database/hbase"
  8. )
  10. func main() {
  11.     config := &hbase.Config{Zookeeper: &hbase.ZKConfig{Addrs: []string{"localhost"}}}
  12.     client := hbase.NewClient(config)
  14.     // 
  15.     values := map[string]map[string][]byte{"name": {"firstname": []byte("hello"), "lastname": []byte("world")}}
  16.     ctx := context.Background()
  18.     // 写入信息
  19.     // table: user
  20.     // rowkey: user1
  21.     // values["family"] = columns
  22.     _, err := client.PutStr(ctx, "user", "user1", values)
  23.     if err != nil {
  24.         panic(err)
  25.     }
  27.     // 读取信息
  28.     // table: user
  29.     // rowkey: user1
  30.     result, err := client.GetStr(ctx, "user", "user1")
  31.     if err != nil {
  32.         panic(err)
  33.     }
  34.     fmt.Printf("%v", result)
  35. }