Связаться с намиПодключиться

Начало работы с Workflows

Статья создана
Обновлена 3 декабря 2024 г.

Примечание

Workflows находится на стадии Preview. Чтобы получить доступ, отправьте заявку в консоли управления.

С помощью этой инструкции вы создадите рабочий процесс и запустите его. Во время выполнения рабочего процесса будут вызываться функции Yandex Cloud Functions.

Перед началом работы

Чтобы начать работать в Yandex Cloud:

  1. Войдите в консоль управления. Если вы еще не зарегистрированы, перейдите в консоль управления и следуйте инструкциям.
  2. На странице Биллинг убедитесь, что у вас подключен платежный аккаунт, и он находится в статусе ACTIVE или TRIAL_ACTIVE. Если платежного аккаунта нет, создайте его.
  3. Если у вас еще нет каталога, создайте его.

Создайте сервисный аккаунт

  1. В консоли управления выберите нужный каталог.
  2. В списке сервисов выберите Identity and Access Management.
  3. Нажмите кнопку Создать сервисный аккаунт.
  4. Введите имя сервисного аккаунта: sa-for-function.
  5. Нажмите кнопку Добавить роль и выберите роль functions.functionInvoker.
  6. Нажмите кнопку Создать.

Создайте функцию, которая фильтрует данные

  1. В консоли управления выберите сервис Cloud Functions.
  2. Создайте функцию:
    1. В правом верхнем углу нажмите кнопку Создать функцию.
    2. Введите имя функции: filter-function.
    3. Нажмите кнопку Создать.
  3. Создайте версию функции:
    1. В открывшемся окне Редактор выберите Node.js 18.
    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. В консоли управления выберите сервис Cloud Functions.
  2. Создайте функцию:
    1. В правом верхнем углу нажмите кнопку Создать функцию.
    2. Введите имя функции: return-function.
    3. Нажмите кнопку Создать.
  3. Создайте версию функции:
    1. В открывшемся окне Редактор выберите Node.js 18.
    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. Нажмите кнопку Сохранить изменения.

Создайте рабочий процесс

  1. В консоли управления выберите сервис Serverless Integrations.

  2. Перейдите на вкладку Workflows.

  3. В правом верхнем углу нажмите кнопку Создать рабочий процесс.

  4. Введите имя рабочего процесса.

  5. В поле Сервисный аккаунт укажите сервисный аккаунт sa-for-function.

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

    • в шаге process_user_transform_info идентификатор функции filter-function;
    • в шаге 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})'

  7. Нажмите кнопку Создать.

Запустите рабочий процесс

  1. Выберите рабочий процесс.
  2. В правом верхнем углу нажмите Запустить.
  3. Введите входные данные в формате JSON: 
    {
  "resource_type": "users"
}
  4. Когда статус рабочего процесса изменится с Выполняется на Выполнен, в блоке Данные на выходе появится следующий 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"
  ]
}

Что дальше

Предыдущая
Обзор
Следующая
EventRouter