Использование SDK для функции на Java
Среда выполнения не содержит предустановленной библиотеки для работы с API Yandex Cloud. Для ее использования требуется добавить зависимость в приложение на Java. Исходный код библиотеки находится на GitHub. Доступность модулей библиотеки зависит от версии языка:
java-sdk-functions— только для Java 11.java-sdk-serverless— для Java 17 и выше.
Другие модули доступны для любой версии Java.
SDK (Software Development Kit) позволяет управлять ресурсами Yandex Cloud от имени сервисного аккаунта, который указан в параметрах функции.
Пример
Следующая функция получает на вход идентификатор каталога (folderId), авторизуется в SDK, получает список всех виртуальных машин Compute Cloud в заданном каталоге и запускает остановленные машины. В качестве результата возвращает сообщение-отчет с количеством запущенных машин.
Важно
Функцию необходимо вызывать с помощью Yandex Cloud CLI или с помощью HTTP-запроса с параметром ?integration=raw.
import yandex.cloud.api.compute.v1.InstanceOuterClass;
import yandex.cloud.api.compute.v1.InstanceServiceGrpc;
import yandex.cloud.api.compute.v1.InstanceServiceOuterClass;
import yandex.cloud.sdk.ServiceFactory;
import yandex.cloud.sdk.auth.Auth;
import java.util.function.Function;
public class Handler implements Function<String, String> {
@Override
public String apply(String folderId) {
// Авторизация в SDK через сервисный аккаунт
var defaultComputeEngine = Auth.computeEngineBuilder().build();
var factory = ServiceFactory.builder()
.credentialProvider(defaultComputeEngine)
.build();
var instanceService = factory.create(InstanceServiceGrpc.InstanceServiceBlockingStub.class, InstanceServiceGrpc::newBlockingStub);
var listInstancesRequest = InstanceServiceOuterClass.ListInstancesRequest.newBuilder().setFolderId(folderId).build();
// Получение списка ВМ по заданному в запросе folderId
var listInstancesResponse = instanceService.list(listInstancesRequest);
var instances = listInstancesResponse.getInstancesList();
var count = 0;
for (var instance : instances) {
if (instance.getStatus() != InstanceOuterClass.Instance.Status.RUNNING) {
var startInstanceRequest = InstanceServiceOuterClass.StartInstanceRequest.newBuilder().setInstanceId(instance.getId()).build();
// Запуск ВМ с указанными в запросе идентификаторами ВМ
var startInstanceResponse = instanceService.start(startInstanceRequest);
if (!startInstanceResponse.hasError()) {
count++;
}
}
}
return String.format("Started %d instances", count);
}
}