Go 客户端

Slack Docker Pulls GitHub edit source

Alluxio有一个Go 语言客户端, 此客户端通过REST API 和Alluxio进行交互。Go 客户端提供一个和原生文件系统Java客户端相似的API。 查看godoc 获取所有可用接口的详细信息，godoc包括如何下载，上传Alluxio中的文件，检查文件是否 存在，列出文件状态等信息。

Alluxio 代理依赖

Go 语言客户端通过Alluxio代理提供的REST API和Alluxio进行交互。

Alluxio代理是一个独立运行的server，可通过命令${ALLUXIO_HOME}/bin/alluxio-start.sh proxy启动， ${ALLUXIO_HOME}/bin/alluxio-stop.sh proxy停止服务，默认情况下，REST API使用端口39999。

使用HTTP代理会影响性能，尤其是在使用代理时会增加一个额外的跳计数，所以推荐让代理服务和一个Alluxio worker运行在一个计算节点上。

安装Go语言客户端相关库

  1. $ go get -d github.com/Alluxio/alluxio-go

示例使用程序

如果本地没有Alluxio代理在运行，将下面的”localhost”替换为代理的主机名。

  1. package main
  3. import (
  4.     "fmt"
  5.     "io/ioutil"
  6.     "log"
  7.     "strings"
  8.     "time"
  10.     alluxio "github.com/alluxio/alluxio-go"
  11.     "github.com/alluxio/alluxio-go/option"
  12. )
  14. func write(fs *alluxio.Client, path, s string) error {
  15.     id, err := fs.CreateFile(path, &option.CreateFile{})
  16.     if err != nil {
  17.         return err
  18.     }
  19.     defer fs.Close(id)
  20.     _, err = fs.Write(id, strings.NewReader(s))
  21.     return err
  22. }
  24. func read(fs *alluxio.Client, path string) (string, error) {
  25.     id, err := fs.OpenFile(path, &option.OpenFile{})
  26.     if err != nil {
  27.         return "", err
  28.     }
  29.     defer fs.Close(id)
  30.     r, err := fs.Read(id)
  31.     if err != nil {
  32.         return "", err
  33.     }
  34.     defer r.Close()
  35.     content, err := ioutil.ReadAll(r)
  36.     if err != nil {
  37.         return "", err
  38.     }
  39.     return string(content), err
  40. }
  42. func main() {
  43.     fs := alluxio.NewClient("localhost", 39999, 10*time.Second)
  44.     path := "/test_path"
  45.     exists, err := fs.Exists(path, &option.Exists{})
  46.     if err != nil {
  47.         log.Fatal(err)
  48.     }
  49.     if exists {
  50.         if err := fs.Delete(path, &option.Delete{}); err != nil {
  51.             log.Fatal(err)
  52.         }
  53.     }
  54.     if err := write(fs, path, "Success"); err != nil {
  55.         log.Fatal(err)
  56.     }
  57.     content, err := read(fs, path)
  58.     if err != nil {
  59.         log.Fatal(err)
  60.     }
  61.     fmt.Printf("Result: %v\n", content)
  62. }