예: Go App Engine 애플리케이션

이 예는 Go로 작성된 App Engine 애플리케이션으로, Bigtable을 사용하여 Google 계정의 방문 수를 추적하는 웹 인터페이스를 제공합니다. 이 예는 Docker 컨테이너에서 로컬로 실행되거나 App Engine의 가변형 환경에 있는 클라우드에서 실행됩니다. 이 애플리케이션의 코드는 GitHub 저장소 GoogleCloudPlatform/golang-samples의 bigtable/usercounter 디렉터리에 있습니다.

코드 샘플 개요

이 코드 샘플은 먼저 Bigtable용 관리 클라이언트를 만듭니다. 그런 다음 클라이언트를 사용하여 사용자가 지정한 Bigtable 인스턴스에서 이름이 emails인 단일 column family가 있는 user-visit-counter 테이블을 확인합니다. 필요한 경우 테이블 및 column family를 만듭니다.

adminClient, err := bigtable.NewAdminClient(ctx, project, instance)
if err != nil {
	log.Fatalf("Unable to create a table admin client. %v", err)
}
tables, err := adminClient.Tables(ctx)
if err != nil {
	log.Fatalf("Unable to fetch table list. %v", err)
}
if !sliceContains(tables, tableName) {
	if err := adminClient.CreateTable(ctx, tableName); err != nil {
		log.Fatalf("Unable to create table: %v. %v", tableName, err)
	}
}
tblInfo, err := adminClient.TableInfo(ctx, tableName)
if err != nil {
	log.Fatalf("Unable to read info for table: %v. %v", tableName, err)
}
if !sliceContains(tblInfo.Families, familyName) {
	if err := adminClient.CreateColumnFamily(ctx, tableName, familyName); err != nil {
		log.Fatalf("Unable to create column family: %v. %v", familyName, err)
	}
}
adminClient.Close()

그런 다음 이후의 모든 읽기 및 쓰기에 사용되는 단일 Bigtable 클라이언트를 만듭니다.

client, err = bigtable.NewClient(ctx, project, instance)
if err != nil {
	log.Fatalf("Unable to create data operations client. %v", err)
}

마지막으로 App Engine 서버의 루트에 HTTP 핸들러를 추가합니다. 핸들러는 요청이 있을 때마다 사용자에게 로그인하라는 메시지를 필요에 따라 표시합니다. 그런 다음 사용자의 이메일 주소 행에서 Increment 작업을 수행하여 사용자의 방문을 추적합니다.

tbl := client.Open(tableName)
rmw := bigtable.NewReadModifyWrite()
rmw.Increment(familyName, u.Email, 1)
row, err := tbl.ApplyReadModifyWrite(ctx, u.Email, rmw)
if err != nil {
	return &appError{err, "Error applying ReadModifyWrite to row: " + u.Email, http.StatusInternalServerError}
}

행을 증분하면 핸들러는 현재 사용자의 총 방문 수를 보여주는 HTML 페이지를 표시합니다.