Auf Speichergruppen für die Datenübertragung zugreifen

Google stellt Codebeispiele und -bibliotheken für Google Cloud Storage bereit. Anhand des folgenden Java-Beispiels zum Lesen einer Datei aus einer Ad Manager-Cloudspeichergruppe können Sie nachvollziehen, wie die eingerichteten Komponenten sich möglicherweise auf Ihren Code auswirken:

• Projektname: Name des Google Cloud Storage-Projekts

• E-Mail-Adresse des Dienstkontos: Generierte E-Mail-Adresse

• .p12-Schlüsseldatei: Heruntergeladene Datei

• Gruppenname: Dieser Name wird von Google bereitgestellt, wenn Sie eine Funktion aktivieren, bei der Ad Manager-Cloudspeichergruppen zum Einsatz kommen.

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 {
    /**
     * Der Name des Projekts, unter dem das Dienstkonto erstellt wurde.
     * 
     * Diese Informationen werden in der Google Developers Console angezeigt.
     */
    private static final String PROJECT_NAME = "Projektname";

    /**
     * Die Developer-E-Mail-Adresse des Dienstkontos.
     * 
     * Diese E-Mail-Adresse wird bei der Erstellung einer Dienstkonto-Client-ID in 
     * Ihrer Google Developers Console erstellt und kann auf der Seite 
     * "Anmeldedaten" abgerufen werden. 
     */
    private static final String SERVICE_ACCOUNT_EMAIL = "Dienstkonto-E-Mail-Adresse";

    /**
     * Gruppe für Speichervorgänge.
     * 
     * Der Name dieser Gruppe wurde von Ihrem Account
     * Manager bereitgestellt. Sie hat vermutlich einen Namen im Format "gdfp-12345678" oder
     * "gdfp_cookieupload_12345678", je nachdem, welches Ad Manager-Add-on Sie verwenden.
     */
    private static final String BUCKET_NAME = "bucket name";

    /**
     * Google Cloud Storage OAuth 2.0 scope for read/write. Dieser sollte
     * den Zugriffsrechten der Gruppe für die Berechtigung „Datenübertragungsgruppen ansehen“  
     * entsprechen. Sie können keine Zugriffsrechte anfordern, die 
     * nicht über die Berechtigung gewährt werden.
     */
    private static final String STORAGE_SCOPE = 
        "https://www.googleapis.com/auth/devstorage.read_write";

    /**
     * Pfad zur .p12-Schlüsseldatei, die Zugriff auf die Gruppe gewährt.
     * 
     * Diese Datei wird bei Erzeugung der Serviceclient-ID generiert. Falls Sie diese Datei
     * nicht besitzen, müssen Sie eine neue .p12-Schlüsseldatei aus der 
     * Google Developers Console generieren.
     */
    private static final String KEY_P12 = "Pfad zur .p12-Schlüsseldatei";

    /** HTTP-Transport. */
    private HttpTransport httpTransport;
    private Storage storage;

    // Konstruktor zum Einrichten von Anmeldedaten und Speicherobjekten
    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);
	}
    }

    /**
     * Methode, um den Namen der ersten Datei in der Gruppe abzurufen.
     * 
     * @return – gibt den Namen der Datei zurück oder null, wenn die Gruppe leer ist
     * @throws IOException – gibt IO-Ausnahmefehler aus
     */
    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();

	// leerer Bucket?
	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("First object in bucket: \"" + object.getName()
		+ "\".");
	return object.getName();
    }

    /**
     * Methode zum Herunterladen der angegebenen Datei aus der Speichergruppe
     * 
     * @param-Dateiname
     *            Name der herunterzuladenden Datei.
     * @throws IOException – gibt IO-Ausnahmefehler aus
     */
    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("File \"" + filename + "\" downloaded.");
    }

    /**
     * Wichtigste Methode zur Ausführung der verschiedenen Tests.
     * 
     * @param-Argumente
     */
    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());
	}
    }
}