Выполнение SQL-запросов к базам данных

Примечание

На данный момент Workflows поддерживается в двух интерфейсах — Yandex Cloud и Yandex AI Studio. При этом:

  • рабочие процессы, созданные в интерфейсе Yandex Cloud, автоматически доступны в интерфейсе AI Studio;
  • рабочие процессы, созданные в интерфейсе AI Studio, недоступны в интерфейсе Yandex Cloud.

С 4 сентября 2026 года Workflows перестанет поддерживаться в интерфейсе Yandex Cloud. Для создания рабочих процессов и управления ими используйте интерфейс AI Studio.

Совет

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

  1. В процессе создания нового рабочего процесса или изменения существующего в интерфейсе AI Studio в правом верхнем углу выберите Конструктор.

  2. Нажмите на блок Добавить первый шаг или значок рядом с шагом, после которого хотите добавить новый.

  3. В разделе Интеграционные шаги выберите Yandex Cloud → Database Query.

  4. В правой части окна:

    1. В блоке Параметры подключения выберите:

      • Подключение, чтобы создать подключение к базе данных.

        1. Укажите в поле:

          • Тип базы данных — тип базы данных, к которой нужно подключиться.

            Для базы данных MySQL® устанавливается кодировка utf8mb4 для значений полей.

          • Хост — адрес сервера базы данных.

          • Порт — порт для подключения к базе данных.

          • База данных — имя базы данных.

        2. Выберите Использовать SSL, чтобы подключаться к базе данных, используя SSL-соединение.

          Если опция выбрана, для базы данных:

          • PostgreSQL включается шифрование SSL.
          • ClickHouse® разрешаются защищенные SSL-соединения.

        3. В блоке Аутентификация выберите:

          • Пароль, чтобы подключаться к базе данных, используя имя пользователя и пароль. Укажите имя пользователя и выберите:

            • Lockbox, чтобы хранить пароль в секрете Yandex Lockbox, и в блоке Cекрет выберите секрет, его версию и ключ, в которых сохранен пароль.

              Если у вас еще нет секрета Yandex Lockbox, нажмите кнопку Создать, чтобы создать его.

            • Текст, чтобы хранить пароль в спецификации в виде текста, и в поле Значение введите пароль.

              Важно

              Хранить пароль в открытом виде в тексте спецификации небезопасно.

          • IAM-токен, чтобы подключаться к базе данных, используя IAM-токен сервисного аккаунта, указанного в настройках рабочего процесса.

            Примечание

            Аутентификация по IAM-токену доступна только для базы данных YDB.

      • DSN, чтобы указать строку подключения к базе данных.

    2. В поле SQL-запрос укажите SQL-запрос, который нужно выполнить.

    3. В поле Метод выполнения выберите:

      • Exec, чтобы выполнить SQL-запрос и вернуть только служебные поля, например RowsAffected и LastInsertId.
      • Query, чтобы выполнить SQL-запрос и вернуть результат.

    4. (Опционально) В поле Таймаут, мс задайте максимальное время выполнения текущего шага.

    5. (Опционально) Чтобы задать для шага собственную политику повторных попыток, разверните блок Политика повторных попыток и нажмите кнопку Политика повторных попыток. В появившейся форме:

      1. (Опционально) В поле Начальная задержка, мс задайте начальное значение задержки между повторными попытками выполнения шага.

      2. (Опционально) В поле Скорость изменения задержки задайте коэффициент, на который будет умножаться время задержки перед каждой повторной попыткой выполнения шага.

      3. (Опционально) В поле Максимальная задержка, мс задайте значение максимальной задержки между повторными попытками выполнения шага.

      4. В поле Ошибки выберите ошибки, для которых будут (или, наоборот, не будут) сделаны повторные попытки выполнения шага.

        Подробная информация о возможных ошибках приведена в разделе Возможные коды ошибок.

      5. (Опционально) В поле Количество повторных попыток задайте максимальное количество повторных попыток выполнения шага.

      6. В поле Режим выбора ошибок выберите:

        • INCLUDE — чтобы делать для шага повторные попытки выполнения при возникновении ошибок, указанных в поле Ошибки.
        • EXCLUDE — чтобы делать для шага повторные попытки выполнения при возникновении любых ошибок, за исключением ошибок, указанных в поле Ошибки.

      Если вы хотите удалить политику повторных попыток, ранее созданную для шага, в строке Политика повторных попыток нажмите и выберите Удалить.

      Если для шага не настроена собственная политика повторных попыток, к нему будет применяться политика повторных попыток, заданная для всего рабочего процесса.

    6. (Опционально) Разверните блок Дополнительные параметры:

      1. Задайте описание шага рабочего процесса.
      2. В поле Фильтр входных данных шага задайте jq-шаблон для фильтрации состояния рабочего процесса, которое передается в шаг.
      3. В поле Фильтр выходных данных шага задайте jq-шаблон для фильтрации выходных данных шага, которые добавляются в состояние рабочего процесса.

  5. (Опционально) Добавьте для создаваемого шага правило перехода по ошибкам, которые могут возникать во время выполнения этого шага.

Полезные ссылки

Предыдущая
Workflows
Следующая
Трекер