Connecting to a cluster YTsaurus

You can connect to a YTsaurus cluster:

• From Yandex Cloud VMs.
• Via the internet over HTTPS.

Examples of connection stringsExamples of connection strings

The examples for Linux were tested in the following environment:

• Yandex Cloud VM running Ubuntu 20.04 LTS.
• Bash: 5.0.16.
• Python: 3.8.2; pip3: 20.0.2.
• Go: 1.24.8.

BashBash

Before connecting:

1. If you do not have the Yandex Cloud CLI installed yet, install and initialize it.

2. Install the YTsaurus CLI according to the instructions.

3. Install the dependencies:

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

GoGo

The example uses OAuth token-based authorization.

To connect to your cluster:

1. Install the dependencies:

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

2. Issue an OAuth token.

3. Prepare a sample file for connection:

   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. Run this command:

   go run connect.go -id <YTsaurus_cluster_ID> -token <user_OAuth_token>
   

   You can get the cluster ID with the list of clusters in the folder.

PythonPython

Before connecting:

1. If you do not have the Yandex Cloud CLI installed yet, install and initialize it.

2. Install the YTsaurus CLI according to the instructions.

3. Install the dependencies:

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