Подключение к кластеру YTsaurus

К кластеру YTsaurus можно подключиться:

• С виртуальных машин Yandex Cloud.
• Через интернет по HTTPS.

Примеры строк подключенияПримеры строк подключения

Примеры для Linux проверялись в следующем окружении:

• Виртуальная машина в Yandex Cloud с Ubuntu 20.04 LTS.
• Bash: 5.0.16.
• Python: 3.8.2; pip3: 20.0.2.
• Go: 1.24.8.

BashBash

Перед подключением:

1. Если у вас еще нет интерфейса командной строки Yandex Cloud (CLI), установите и инициализируйте его.

2. Установите YTsaurus CLI по инструкции.

3. Установите зависимости:

   sudo apt update && sudo apt install -y python3 python3-pip && \
   pip3 install ytsaurus-client-yc-auth
   

GoGo

В примере используется авторизация при помощи OAuth-токена.

Чтобы подключиться к кластеру:

1. Установите зависимости:

   sudo apt update && sudo apt install --yes golang git && \
   go mod init example && go get go.ytsaurus.tech/yt/go
   

2. Выпустите OAuth-токен.

3. Подготовьте пример файла для подключения:

   connect.go

   package main
   
   import (
       "context"
       "flag"
       "fmt"
       "time"
   
       ycsdk "github.com/yandex-cloud/go-sdk"
       ytsdk "go.ytsaurus.tech/yt/go/yt"
       ythttpsdk "go.ytsaurus.tech/yt/go/yt/ythttp"
   )
   
   func main() {
       clusterID := flag.String("id", "", "YTsaurus cluster ID")
       token := flag.String("token", "", "OAuth token")
       flag.Parse()
   
       ctx := context.Background()
   
       sdk, err := ycsdk.Build(ctx, ycsdk.Config{
           Credentials: ycsdk.OAuthToken(*token),
       })
       if err != nil {
           panic(err)
       }
   
       iamTokenProvider, err := IamTokenProvider(ctx, sdk)
       if err != nil {
           panic(err)
       }
   
       timeout := 10 * time.Second
       client, err := ythttpsdk.NewClient(&ytsdk.Config{
           Proxy:                 fmt.Sprintf("https://%s.proxy.ytsaurus.yandexcloud.net", *clusterID),
           LightRequestTimeout:   &timeout,
           DisableProxyDiscovery: true,
           CredentialsProviderFn: iamTokenProvider,
       })
       if err != nil {
           panic(err)
       }
   
       res, err := client.WhoAmI(context.Background(), nil)
       if err != nil {
           panic(err)
       }
   
       fmt.Printf("Logged in as %s\n", res.Login)
   }
   
   func IamTokenProvider(ctx context.Context, sdk *ycsdk.SDK) (ytsdk.CredentialsProviderFn, error) {
       var now = time.Now
       tokenMiddleware := ycsdk.NewIAMTokenMiddleware(sdk, now)
       return func(ctx context.Context) (ytsdk.Credentials, error) {
           currentToken, err := tokenMiddleware.GetIAMToken(ctx, false)
           if err != nil {
               return nil, err
           }
           return &ytsdk.BearerCredentials{Token: currentToken}, nil
       }, nil
   }
   

4. Выполните команду:

   go run connect.go -id <идентификатор_кластера_YTsaurus> -token <OAuth_токен_пользователя>
   

   Идентификатор кластера можно запросить со списком кластеров в каталоге.

PythonPython

Перед подключением:

1. Если у вас еще нет интерфейса командной строки Yandex Cloud (CLI), установите и инициализируйте его.

2. Установите YTsaurus CLI по инструкции.

3. Установите зависимости:

   sudo apt update && sudo apt install -y python3 python3-pip && \
   pip3 install ytsaurus-client-yc-auth