Взаимодействие с документными таблицами в базе данных Yandex Managed Service for YDB

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

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

В разделе Интеграционные шаги выберите Yandex Cloud → Managed Service for YDB.

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

1. В поле База данных выберите базу данных. Поддерживаются только базы данных, созданные в режиме Serverless.

2. В поле Путь к таблице укажите путь к таблице, с которой рабочий процесс будет взаимодействовать. Поддерживаются только документные таблицы.

3. В блоке Действие выберите:

   • Get, чтобы получить содержимое элемента в базе данных, и в поле Ключ задайте значение первичного ключа БД, относящегося к нужному элементу.

   • Put, чтобы записать данные в таблицу, и в поле Атрибуты задайте ассоциативный массив атрибутов в формате ключ/значение.

   • Update, чтобы изменить данные в таблице, и настройте параметры обновления:

     1. В поле Ключ задайте значение первичного ключа элемента в базе данных, который нужно обновить.
     2. В поле Выражение для обновления задайте выражение, описывающее обновление атрибутов элемента в базе данных. Подробнее о параметре UpdateExpression в документации Yandex Managed Service for YDB.
     3. В поле Значения атрибутов задайте значения атрибутов, используемых в выражении выше. Подробнее о параметре ExpressionAttributeValues в документации Yandex Managed Service for YDB.

   • Scan, чтобы выполнить поиск в базе данных, и настройте параметры поиска:

     1. В поле Ключ задайте значение первичного ключа элемента в базе данных, с которого начнется поиск.
     2. В поле Лимит задайте ограничение на максимальное количество элементов в списке с результатами.

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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