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

В этом разделе представлены настройки для подключения к кластеру Managed Service for Trino с помощью инструментов командной строки, из графических IDE и WebSQL. О подключении из кода вашего приложения см. Примеры строк подключения.

Подключаться к кластеру Managed Service for Trino, у которого включен приватный доступ, можно только из той сети, в которой расположен кластер.

Настройка групп безопасностиНастройка групп безопасности

Группы безопасности не ограничивают входящий трафик кластера Managed Service for Trino и не влияют на доступность веб-интерфейса Trino. Настраивать правила для входящего трафика не нужно.

Вы можете использовать группы безопасности, чтобы задавать правила для исходящего трафика, например при настройке нового каталога.

Чтобы подключаться к кластеру Trino с виртуальной машины в Yandex Cloud, настройте группу безопасности ВМ, с которой будет происходить подключение. Пример правил для ВМ:

• Для входящего трафика:

  • Диапазон портов — 22.
  • Протокол — TCP.
  • Источник — CIDR.
  • CIDR блоки — 0.0.0.0/0.

  Это правило позволяет подключаться к ВМ по протоколу SSH.

• Для исходящего трафика:

  • Протокол — Любой (Any).
  • Диапазон портов — 0-65535.
  • Назначение — CIDR.
  • CIDR блоки — 0.0.0.0/0.

  Это правило разрешает любой исходящий трафик, что позволяет не только подключаться к кластеру, но и устанавливать на ВМ необходимые для этого утилиты.

Группы безопасности для работы с Yandex MPP Analytics for PostgreSQLГруппы безопасности для работы с Yandex MPP Analytics for PostgreSQL

Для подключения к кластеру Yandex MPP Analytics for PostgreSQL коннектор использует протокол GPFDIST:

• Координаторы и воркеры Trino выполняют запросы к мастеру Yandex MPP Analytics for PostgreSQL через TCP-порт 6432.
• Сегменты Yandex MPP Analytics for PostgreSQL передают данные на воркеры Trino через TCP-порт GPFDIST из диапазона 30078–30085.

Данные, передающиеся по протоколу GPFDIST между кластерами Yandex MPP Analytics for PostgreSQL и Trino, не шифруются. Чтобы обеспечить безопасное подключение, настройте группы безопасности на стороне Yandex MPP Analytics for PostgreSQL и (опционально) на стороне Managed Service for Trino.

Настройка на стороне Yandex MPP Analytics for PostgreSQLНастройка на стороне Yandex MPP Analytics for PostgreSQL

Настройка на стороне Managed Service for TrinoНастройка на стороне Managed Service for Trino

Правила групп безопасности на стороне Trino настраиваются зеркально правилам на стороне Yandex MPP Analytics for PostgreSQL. Настройка правил для кластера Trino является опциональной, но позволяет дополнительно обезопасить кластер.

Инструменты командной строкиИнструменты командной строки

Trino CLITrino CLI

Если у вас еще нет интерфейса командной строки Trino, установите его по инструкции на официальном сайте Trino.

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

1. Создайте IAM-токен и поместите его в переменную окружения TRINO_PASSWORD:

   export TRINO_PASSWORD=$(yc iam create-token)
   

   IAM-токен, хранящийся в переменной TRINO_PASSWORD, служит паролем для подключения к кластеру Managed Service for Trino. Чтобы использовать его, укажите при подключении флаг --password.

2. Подключитесь к кластеру Managed Service for Trino:

   ./trino c-<идентификатор_кластера>.trino.yandexcloud.net --user iam --password
   

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

Подключение из графических IDEПодключение из графических IDE

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

1. Создайте IAM-токен:

   yc iam create-token
   

2. Сохраните полученный токен. Он будет использоваться в качестве пароля при подключении.

WebSQLWebSQL

1. Перейдите на страницу каталога.

2. Перейдите в сервис Managed Service for Trino.

3. Откройте ваш кластер Managed Service for Trino.

4. Перейдите в раздел WebSQL.

5. Нажмите кнопку Перейти в WebSQL.

6. В открывшемся редакторе SQL-запросов выполните запрос:

   SELECT version() AS version;
   

   В ответе на запрос будет информация о версии Trino.

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

PythonPython

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

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

   pip3 install trino
   

2. Создайте IAM-токен и поместите его в переменную окружения TOKEN:

   export TOKEN=$(yc iam create-token)
   

JavaJava

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

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

   sudo apt update && sudo apt install --yes openjdk-21-jre maven
   

2. Создайте директорию для проекта Maven:

   cd ~/ && mkdir -p project/src/main/java/com/example && cd project/
   

3. Создайте конфигурационный файл для Maven:

   pom.xml

   <?xml version="1.0" encoding="utf-8"?>
   <project xmlns="http://maven.apache.org/POM/4.0.0"
           xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
           xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
   
       <modelVersion>4.0.0</modelVersion>
       <groupId>com.example</groupId>
       <artifactId>app</artifactId>
       <version>0.1.0</version>
       <packaging>jar</packaging>
       <properties>
           <maven.compiler.source>21</maven.compiler.source>
           <maven.compiler.target>21</maven.compiler.target>
           <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
       </properties>
       <dependencies>
           <dependency>
               <groupId>io.trino</groupId>
               <artifactId>trino-jdbc</artifactId>
               <version>469</version>
           </dependency>
       </dependencies>
       <build>
           <finalName>${project.artifactId}-${project.version}</finalName>
           <plugins>
               <plugin>
                   <groupId>org.apache.maven.plugins</groupId>
                   <artifactId>maven-assembly-plugin</artifactId>
                   <version>3.7.1</version>
                   <executions>
                       <execution>
                           <goals>
                               <goal>single</goal>
                           </goals>
                           <phase>package</phase>
                           <configuration>
                               <descriptorRefs>
                                   <descriptorRef>
                                       jar-with-dependencies</descriptorRef>
                               </descriptorRefs>
                               <archive>
                                   <manifest>
                                       <mainClass>com.example.App</mainClass>
                                   </manifest>
                               </archive>
                           </configuration>
                       </execution>
                   </executions>
               </plugin>
               <plugin>
                   <groupId>org.apache.maven.plugins</groupId>
                   <artifactId>maven-jar-plugin</artifactId>
                   <version>3.4.2</version>
                   <configuration>
                       <archive>
                           <manifest>
                               <mainClass>com.example.App</mainClass>
                           </manifest>
                       </archive>
                   </configuration>
               </plugin>
           </plugins>
       </build>
   </project>
   
   

4. Создайте IAM-токен и поместите его в переменную окружения TOKEN:

   export TOKEN=$(yc iam create-token)
   

Node.jsNode.js

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

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

   sudo apt update && sudo apt install --yes nodejs npm && \
   npm install trino-client
   

2. Создайте IAM-токен и поместите его в переменную окружения TOKEN:

   export TOKEN=$(yc iam create-token)
   

"use strict";
import {BasicAuth, Trino} from 'trino-client';

const COORDINATOR_URL = 'c-<идентификатор_кластера>.trino.yandexcloud.net'
let TOKEN = process.env.TOKEN

async function get_version() {
    const trino = Trino.create({server: COORDINATOR_URL,auth: new BasicAuth('iam', TOKEN)});
    const query = await trino.query('SELECT version() as VERSION');
    const queryResult = await query.next()
    console.log(queryResult.value.data[0][0])
}

get_version();

Подключение:

node app.mjs