Вызвать функцию асинхронно
Статья создана
Обновлена 15 февраля 2024 г.
Примечание
Функциональность находится на стадии Preview.
Настройте асинхронный вызов
Консоль управления
CLI
API
- В консоли управления
перейдите в каталог, в котором находится функция. - Выберите сервис Cloud Functions.
- Выберите функцию.
- Перейдите на вкладку Редактор.
- В блоке Асинхронный вызов активируйте переключатель Включить.
- В поле Количество повторных попыток укажите количество повторных вызовов функции, которые будут сделаны, прежде чем вызов будет считаться неуспешным.
- В поле Сервисный аккаунт укажите сервисный аккаунт, у которого есть права на вызов функции.
- Укажите в полях Назначение для успешного результата и Назначение для неуспешного результата, куда отправлять сообщения об успешном и неуспешном вызовах функции соответственно:
Не задано
— не отправлять сообщения.Message Queue
— отправлять сообщения в очередь Message Queue:- Очередь сообщений — очередь Message Queue, в которую нужно отправлять сообщения.
- Сервисный аккаунт — сервисный аккаунт, у которого есть права на запись в очередь.
- Нажмите кнопку Сохранить изменения.
Если у вас еще нет интерфейса командной строки Yandex Cloud, установите и инициализируйте его.
По умолчанию используется каталог, указанный в профиле CLI. Вы можете указать другой каталог с помощью параметра --folder-name
или --folder-id
.
Чтобы настроить асинхронный вызов, выполните команду:
yc serverless function version create \
--function-name=<имя_функции> \
--runtime <среда_выполнения> \
--entrypoint <точка_входа> \
--memory 128m \
--execution-timeout 5s \
--source-version-id <идентификатор_версии> \
--async-max-retries 3 \
--async-service-account-id <идентификатор_сервисного_аккаунта> \
--async-success-ymq-arn <очередь_сообщений> \
--async-success-sa-id <идентификатор_сервисного_аккаунта> \
--async-failure-ymq-arn <очередь_сообщений> \
--async-failure-sa-id <идентификатор_сервисного_аккаунта>
Где:
--function-name
— имя функции.--runtime
— среда выполнения.--entrypoint
— точка входа, указывается в формате<имя_файла_с_функцией>.<имя_обработчика>
.--memory
— объем RAM.--execution-timeout
— максимальное время выполнения функции до таймаута.--source-version-id
— идентификатор версии функции, код которой вы хотите скопировать.--async-max-retries
— количество повторных вызовов функции, которые будут сделаны, прежде чем вызов будет считаться неуспешным.--async-service-account-id
— сервисный аккаунт, у которого есть права на вызов функции.--async-success-ymq-arn
— очередь Message Queue, в которую нужно отправлять сообщения об успешных вызовах функции. Если параметр не указан, сообщения не отправляются.--async-success-sa-id
— сервисный аккаунт с правами на запись в очередьasync-success-ymq-arn
.--async-failure-ymq-arn
— очередь Message Queue, в которую нужно отправлять сообщения о неуспешных вызовах функции. Если параметр не указан, сообщения не отправляются.--async-failure-sa-id
— сервисный аккаунт с правами на запись в очередьasync-failure-ymq-arn
.
Чтобы настроить асинхронный вызов, воспользуйтесь методом REST API createVersion для ресурса Function или вызовом gRPC API FunctionService/CreateVersion.
Вызовите функцию
Вызовите функцию по HTTPS, указав параметр строки запроса ?integration=async
.