Accéder aux buckets de stockage liés au transfert de données

Google fournit des exemples de code et des bibliothèques pour Google Cloud Storage. L'exemple de code Java ci-dessous, qui concerne la lecture d'un fichier à partir d'un ensemble de données Ad Manager stockées dans le cloud, vous montre comment les composants que vous avez configurés lors de la création du compte de service interagissent avec votre code.

• Nom du projet : nom du projet Google Cloud Storage.

• Adresse e-mail du compte de service : adresse e-mail générée.

• Fichier clé .p12 : fichier téléchargé.

• Nom du bucket : nom fourni par Google lors de l'activation d'une fonctionnalité utilisant les buckets Ad Manager de stockage dans le cloud.

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 {
    /**
     * Nom du projet dans lequel le compte de service a été créé.
     * 
     * Ces informations sont affichées dans la Google Developers Console.
     */
    private static final String PROJECT_NAME = "nom du projet" ;

    /**
     * Adresse e-mail du compte de service du développeur.
     * 
     * Cette adresse e-mail est générée lors de la création de l'ID client du compte de service dans votre
     * Google Developers Console. Elle est disponible sur votre page
     * "Identifiants". 
     */
    private static final String SERVICE_ACCOUNT_EMAIL = "adresse e-mail du compte de service" ;

    /**
     * Ensemble à utiliser pour les opérations de stockage
     * 
     * Le nom de cet ensemble vous a été fourni par le responsable
     * de votre compte. Il se présente certainement sous la forme "gdfp-12345678" ou
     * "gdfp_cookieupload_12345678", selon le module complémentaire pour Ad Manager que vous utilisez.
     */
    private static final String BUCKET_NAME = "nom de l'ensemble" ;

    /**
     * Portée OAuth 2.0 de Google Cloud Storage en lecture/écriture. Cela doit
     * correspondre aux droits d'accès de l'autorisation "Afficher les ensembles liés au transfert de données"  
     * pour l'ensemble. Vous ne pouvez pas demander des droits d'accès qui ne sont pas 
     * accordés via l'autorisation.
     */
    private static final String STORAGE_SCOPE = 
        "https://www.googleapis.com/auth/devstorage.read_write";

    /**
     * Chemin vers le fichier clé .p12 donnant accès à l'ensemble.
     * 
     * Ce fichier est créé en même temps que l'ID client de service. Si vous ne disposez pas de
     * ce fichier, vous devez générer une nouvelle clé .p12 cliente à partir de la
     * Google Developers Console.
     */
    private static final String KEY_P12 = "chemin vers le fichier clé .p12" ;

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

    // Constructeur, définition des identifiants et des objets de stockage
    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);
	}
    }

    /**
     * Méthode permettant de renvoyer le nom du premier fichier dans le bucket.
     * 
     * @renvoie le nom du fichier ou rien si le bucket est vide
     * @déclenche 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();

	// bucket vide ?
	si (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();
    }

    /**
     * Méthode permettant de télécharger le fichier spécifié dans le bucket de stockage
     * 
     * @param nom de fichier
     *            Nom du fichier à télécharger.
     * @déclenche 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("File \"" + filename + "\" downloaded.");
    }

    /**
     * Méthode principale pour exécuter différents tests.
     * 
     * @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());
	}
    }
}