Доступ к сегментам передачи данных

Google предоставляет примеры кода и библиотек для Google Cloud Storage. Ниже приведен пример кода Java, который считывает файл из сегмента облачного хранилища Менеджера рекламы. Этот пример поможет вам понять, как использовать в коде созданные выше компоненты.

• Project name. Название проекта Google Cloud Storage.

• Service account email address. Адрес электронной почты, созданный в процессе настройки аккаунта сервиса.

• .p12 key file. Файл ключа P12, скачанный в процессе настройки.

• Bucket name. Название сегмента, предоставленного вам Google при активации функции, в которой используются сегменты облачного хранилища Менеджера рекламы.

import java.io.File;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.OutputStream;
import java.security.GeneralSecurityException;
import java.util.Collections;

import com.google.api.client.googleapis.auth.oauth2.GoogleCredential;
import com.google.api.client.googleapis.javanet.GoogleNetHttpTransport;
import com.google.api.client.http.HttpTransport;
import com.google.api.client.json.jackson2.JacksonFactory;
import com.google.api.services.storage.Storage;
import com.google.api.services.storage.model.StorageObject;

public class GcsApiTest {
    /**
     * Название проекта, которое использовалось при создании сервисного аккаунта.
     * 
     * Эта информация доступна в Google Developers Console.
     */
    private static final String PROJECT_NAME = "название проекта";

    /**
     * Адрес электронной почты разработчика, указанный в сервисном аккаунте.
     * 
     * Этот адрес электронной почты генерируется после создания
     * идентификатора клиента при настройке сервисного аккаунта
     * в Google Developers Console. Его можно найти
     * на странице учетных данных (Credentials). 
     */
    private static final String SERVICE_ACCOUNT_EMAIL = "адрес электронной почты в сервисном аккаунте";

    /**
     * Сегмент, который будет использоваться для операций хранения.
     * 
     * Название этого сегмента вам должен был предоставить менеджер аккаунта. Приблизительный формат названия – gdfp-12345678 или
     * gdfp_cookieupload_12345678 в зависимости от того, какое дополнение
     * Менеджера рекламы вы используете.
     */
    private static final String BUCKET_NAME = "название сегмента";

    /**
     * Область чтения/записи OAuth 2.0 Google Cloud Storage. Должна
     * соответствовать правам доступа, установленным для разрешения "Просмотр сегментов передачи данных"  
     * для сегмента. Нельзя запрашивать права доступа, которые отличаются от предоставленных 
     * с помощью разрешения.
     */
    private static final String STORAGE_SCOPE = 
        "https://googleapis.com/auth/devstorage.read_write";

    /**
     * Путь к файлу key.p12, который обеспечивает доступ к сегменту.
     * Этот файл создается вместе с идентификатором клиента в аккаунте сервиса. Если у вас
     * нет этого файла, вам нужно создать новый ключ P12
     * в Google Developers Console.
     */
    private static final String KEY_P12 = "путь к файлу ключа P12";

    /** HTTP-транспорт. */
    private HttpTransport httpTransport;
    private Storage storage;

    // Этот конструктор создает учетные данные и объекты хранения.
    public GcsApiTest() {
	File p12File = new File(KEY_P12);

	try {
	    httpTransport = GoogleNetHttpTransport.newTrustedTransport();

	    GoogleCredential credential = new GoogleCredential.Builder()
		    .setTransport(httpTransport)
		    .setJsonFactory(JacksonFactory.getDefaultInstance())
		    .setServiceAccountId(SERVICE_ACCOUNT_EMAIL)
		    .setServiceAccountScopes(
			    Collections.singleton(STORAGE_SCOPE))
		    .setServiceAccountPrivateKeyFromP12File(p12File).build();
	    storage = new Storage.Builder(httpTransport,
		    JacksonFactory.getDefaultInstance(), credential)
		    .setApplicationName(PROJECT_NAME).build();
	} catch (GeneralSecurityException | IOException e1) {
	    e1.printStackTrace();
	    System.exit(1);
	}
    }

    /**
     * Этот метод возвращает имя первого файла в сегменте.
     * 
     * @возвращает имя файла или null, если сегмент пустой.
     * @генерирует исключение IOException.
     */
    public String GetFirstFile() throws IOException {
	Storage.Objects.List listObjects = storage.objects().list(BUCKET_NAME);
	listObjects.setMaxResults(5L);
	com.google.api.services.storage.model.Objects objects = listObjects
		.execute();

	// пустой сегмент?
	if (null == objects.getItems() || objects.getItems().isEmpty()) {
	    System.out.println("Bucket \"" + BUCKET_NAME
		    + "\" empty or invalid.");
	    return null;
	}

	StorageObject object = objects.getItems().get(0);
	System.out.println("Первый объект в сегменте: \"" + object.getName()
		+ "\".");
	return object.getName();
    }

    /**
     * Метод загрузки указанного файла из сегмента хранилища.
     * 
     * @param filename
     *            Имя скачиваемого файла.
     * @генерирует исключение IOException.
     */
    public void DownloadFile(String filename) throws IOException {
	Storage.Objects.Get getObject = storage.objects().get(BUCKET_NAME,
		filename);
	OutputStream os = new FileOutputStream(filename, true);
	getObject.getMediaHttpDownloader().setDirectDownloadEnabled(true);
	getObject.executeMediaAndDownloadTo(os);

	System.out.println("Файл \"" + filename + "\" скачан.");
    }

    /**
     * Основной метод выполнения различных тестов.
     * 
     * @param args
     */
    public static void main(String[] args) {
	GcsApiTest gcsApiTest = new GcsApiTest();

	try {
	    String filename = gcsApiTest.GetFirstFile();
	    gcsApiTest.DownloadFile(filename);
	} catch (IOException e) {
	    System.out.println(e.getMessage());
	}
    }
}