Как начать работать с Workflows

1. В правом верхнем углу нажмите кнопку Создать функцию.
2. Введите имя функции: filter-function.
3. Нажмите кнопку Создать.

1. В открывшемся окне Редактор выберите Node.js 22.
2. Отключите опцию Добавить файлы с примерами кода.
3. Нажмите кнопку Продолжить.
4. Создайте файл index.js и добавьте в него следующий код:

   module.exports.handler = async function (data, context) {
       return {
           id: data.id,
           name: data.name,
           email: data.email,
       };
   };
   
5. В блоке Параметры укажите в поле:
   • Точка входа — index.handler;
   • Сервисный аккаунт — sa-for-function.
6. Нажмите кнопку Сохранить изменения.

1. В правом верхнем углу нажмите кнопку Создать функцию.
2. Введите имя функции: return-function.
3. Нажмите кнопку Создать.

1. В открывшемся окне Редактор выберите Node.js 22.
2. Отключите опцию Добавить файлы с примерами кода.
3. Нажмите кнопку Продолжить.
4. Создайте файл index.js и добавьте в него следующий код:

   module.exports.handler = async function (data, context) {
       return {
           result: "OK",
           emails: data.loaded_users.map(p => p.email)
       };
   };
   
5. В блоке Параметры укажите в поле:
   • Точка входа — index.handler;
   • Сервисный аккаунт — sa-for-function.
6. Нажмите кнопку Сохранить изменения.

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

На панели слева разверните раздел Agent Atelier и выберите Workflows.

Нажмите Создать рабочий процесс.

Выберите способ YaML-спецификация.

Добавьте спецификацию, которая приведена ниже. Укажите в поле functionId:

• на 39 строке в шаге process_user_transform_info — идентификатор функции filter-function;
• на 44 строке в шаге upload_users — идентификатор функции return-function.

yawl: "0.1"
start: get_users
defaultRetryPolicy:
  maxDelay: 10s
  retryCount: 2
  errorList:
    - STEP_QUOTA_EXCEEDED
steps:
  get_users:
    httpCall:
      url: 'https://jsonplaceholder.typicode.com/{{ .resource_type }}'
      method: GET
      headers: {}
      query: {}
      output: '{{ {loaded_users: .} }}'
      next: process_users
  process_users:
    foreach:
      input: {{ .loaded_users }}
      output: '{{ {loaded_users: .} }}'
      next: upload_users
      do:
        start: process_user_get_info
        steps:
          process_user_get_info:
            httpCall:
              url: https://jsonplaceholder.typicode.com/users/{{ .id }}
              method: GET
              headers: {}
              query: {}
              next: process_user_transform_info
              output: '{{ {user: .} }}'
              retryPolicy:
                retryCount: 2
                errorList:
                  - HTTP_CALL_500
          process_user_transform_info:
            functionCall:
              functionId: <идентификатор_функции>
  upload_users:
    functionCall:
      functionId: "<идентификатор_функции>"
      input: '{{ {loaded_users, resource_type} }}'

Нажмите Дополнительные параметры и в поле Сервисный аккаунт выберите сервисный аккаунт sa-for-function.

Нажмите Создать.

Выберите рабочий процесс.

Нажмите Запустить.

Введите входные данные в формате JSON и нажмите кнопку Запустить.

Входные данные в формате JSON:

{
  "resource_type": "users"
}

Когда статус рабочего процесса изменится с Выполняется на Выполнен, в блоке Данные на выходе появится результат в формате JSON:

{
  "result": "OK",
  "emails": [
    "Sincere@april.biz",
    "Shanna@melissa.tv",
    "Nathan@yesenia.net",
    "Julianne.OConner@kory.org",
    "Lucio_Hettinger@annie.ca",
    "Karley_Dach@jasper.info",
    "Telly.Hoeger@billy.biz",
    "Sherwood@rosamond.me",
    "Chaim_McDermott@dana.io",
    "Rey.Padberg@karina.biz"
  ]
}