Data Transfer ストレージ バケットにアクセスする

Google では Google Cloud Storage のサンプルコードとライブラリを提供しています。以下は、アド マネージャーのクラウド ストレージ バケットからファイルを読み取る Java コードの例です。サービス アカウントの設定時に設定した要素がどのようにコードに組み込まれるのかをご確認ください。

• プロジェクト名: Google Cloud Storage プロジェクトの名前です。

• サービス アカウントのメールアドレス: 生成したメールアドレスです。

• .p12 キーファイル: ダウンロードしたファイルです。

• バケット名: アド マネージャーのクラウド ストレージ バケットを使用する機能を有効にするときに 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 = "project name";

    /**
     * サービス アカウントのデベロッパー メールアドレス。
     * 
     * このメールアドレスは、Google Developers Console でサービス アカウントの
     * クライアント ID を作成すると生成され、[認証情報] ページから取得
     * できます。
     */
    private static final String SERVICE_ACCOUNT_EMAIL = "service account email address";

    /**
     * ストレージの操作に使用するバケット。
     * 
     * このバケットの名前は、テクニカル アカウント マネージャーから提供
     * されます。使用しているアド マネージャーのアドオンに応じて、「gdfp-12345678」や
     * 「gdfp_cookieupload_12345678」のような名前になります。
     */
    private static final String BUCKET_NAME = "bucket name";

    /**
     * Google Cloud Storage OAuth 2.0 の読み取り / 書き込みの対象範囲。これは
     * バケットの「データ転送バケットの表示」権限のアクセス権に対応している
     * 必要があります。この権限で付与されていないアクセス権をリクエストすることは
     * できません。
     */
    private static final String STORAGE_SCOPE = 
        "https://googleapis.com/auth/devstorage.read_write";

    /**
     * バケットへのアクセスを可能にする key.p12 ファイルのパス。
     * 
     * このファイルは、サービス クライアント ID の作成時に生成されます。この
     * ファイルがない場合は、Google Developers Console で新しいクライアント
     * P12 キーを生成する必要があります。
     */
    private static final String KEY_P12 = "path to .p12 key file";

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

    /**
     * 指定したファイルをストレージ バケットからダウンロードするためのメソッド。
     * 
     * @パラメータ 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("File \"" + filename + "\" downloaded.");
    }

    /**
     * 各種テストを実行するメインのメソッド。
     * 
     * @パラメータ 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());
	}
    }
}