1. Genel Bakış
Google Cloud Spanner, performanstan ve yüksek kullanılabilirlikten ödün vermeden ACID işlemleri ve SQL semantiği sağlayan, tümüyle yönetilen, yatay olarak ölçeklenebilir, küresel olarak dağıtılmış bir ilişkisel veritabanı hizmetidir.
Bu laboratuvarda, Cloud Spanner örneği oluşturmayı öğreneceksiniz. Oyunlardaki skor tablosu için kullanılabilecek bir veritabanı ve şema oluşturma adımlarını inceleyeceksiniz. Oyuncu bilgilerini depolamak için bir Oyuncular tablosu ve oyuncu puanlarını depolamak için bir Puanlar tablosu oluşturarak başlayacaksınız.
Ardından, tabloları örnek verilerle doldurursunuz. Ardından, bazı İlk On örnek sorgularını çalıştırarak laboratuvarı tamamlayacak ve kaynakları boşaltmak için örneği sileceksiniz.
Neler öğreneceksiniz?
- Cloud Spanner örneği oluşturma
- Veritabanı ve tablolar oluşturma
- Commit zaman damgası sütunu nasıl kullanılır?
- Zaman damgalarıyla Cloud Spanner veritabanı tablonuza veri yükleme
- Cloud Spanner veritabanınızı sorgulama
- Cloud Spanner örneğinizi nasıl sileceğiniz açıklanır.
İhtiyacınız olanlar
Bu eğitimi nasıl kullanacaksınız?
Google Cloud Platform deneyiminizi nasıl değerlendirirsiniz?
2. Kurulum ve Gereksinimler
Yönlendirmesiz ortam kurulumu
Google Hesabınız (Gmail veya Google Apps) yoksa hesap oluşturmanız gerekir. Google Cloud Platform Console'da ( console.cloud.google.com) oturum açın ve yeni bir proje oluşturun.
Önceden oluşturduğunuz bir projeniz varsa konsolun sol üst kısmındaki proje seçimi açılır menüsünü tıklayın:
ve yeni bir proje oluşturmak için açılan iletişim kutusunda "YENİ PROJE" düğmesini tıklayın:
Henüz bir projeniz yoksa ilk projenizi oluşturmak için aşağıdaki gibi bir iletişim kutusu görürsünüz:
Sonraki proje oluşturma iletişim kutusunda yeni projenizin ayrıntılarını girebilirsiniz:
Tüm Google Cloud projelerinde benzersiz bir ad olan proje kimliğini unutmayın (Yukarıdaki ad zaten alınmış olduğundan sizin için çalışmayacaktır). Bu codelab'in ilerleyen kısımlarında PROJECT_ID olarak adlandırılacaktır.
Ardından, henüz yapmadıysanız Google Cloud kaynaklarını kullanmak için Developers Console'da faturalandırmayı etkinleştirmeniz ve Cloud Spanner API'yi etkinleştirmeniz gerekir.
Bu codelab'i tamamlamak size birkaç dolardan fazla maliyet getirmemelidir. Ancak daha fazla kaynak kullanmaya veya kaynakları çalışır durumda bırakmaya karar verirseniz maliyet artabilir (bu belgenin sonundaki "temizleme" bölümüne bakın). Google Cloud Spanner fiyatlandırması burada belgelenmiştir.
Google Cloud Platform'un yeni kullanıcıları, bu codelab'i tamamen ücretsiz hale getirecek 300 ABD doları değerinde ücretsiz deneme sürümünden yararlanabilir.
Google Cloud Shell Kurulumu
Google Cloud ve Spanner, dizüstü bilgisayarınızdan uzaktan çalıştırılabilir ancak bu codelab'de Cloud'da çalışan bir komut satırı ortamı olan Google Cloud Shell'i kullanacağız.
Bu Debian tabanlı sanal makine, ihtiyaç duyacağınız tüm geliştirme araçlarını içerir. 5 GB boyutunda kalıcı bir ana dizin bulunur ve Google Cloud'da çalışır. Bu sayede ağ performansı ve kimlik doğrulama önemli ölçüde güçlenir. Bu nedenle, bu codelab için ihtiyacınız olan tek şey bir tarayıcıdır (Chromebook'ta da çalışır).
- Cloud Shell'i Cloud Console'dan etkinleştirmek için Cloud Shell'i etkinleştir 'i
tıklamanız yeterlidir (ortamın sağlanması ve bağlantının kurulması yalnızca birkaç saniye sürer).
Cloud Shell'e bağlandıktan sonra kimliğinizin doğrulandığını ve projenin, PROJECT_ID'nize ayarlandığını görürsünüz.
gcloud auth list
Komut çıkışı
Credentialed accounts: - <myaccount>@<mydomain>.com (active)
gcloud config list project
Komut çıkışı
[core] project = <PROJECT_ID>
Herhangi bir nedenle proje ayarlanmamışsa şu komutu verin:
gcloud config set project <PROJECT_ID>
PROJECT_ID cihazınızı mı arıyorsunuz? Kurulum adımlarında hangi kimliği kullandığınızı kontrol edin veya Cloud Console kontrol panelinde arayın:
Cloud Shell, gelecekteki komutları çalıştırırken faydalı olabilecek bazı ortam değişkenlerini de varsayılan olarak ayarlar.
echo $GOOGLE_CLOUD_PROJECT
Komut çıkışı
<PROJECT_ID>
- Son olarak, varsayılan alt bölgeyi ve proje yapılandırmasını ayarlayın.
gcloud config set compute/zone us-central1-f
Çeşitli bölgeler arasından seçim yapabilirsiniz. Daha fazla bilgi için Bölgeler ve Alt Bölgeler başlıklı makaleyi inceleyin.
Özet
Bu adımda ortamınızı ayarlarsınız.
Sıradaki
Ardından, Cloud Spanner örneği oluşturacaksınız.
3. Cloud Spanner örneği oluşturma
Bu adımda, bu codelab için Cloud Spanner örneğimizi kuruyoruz. Sol üstteki hamburger menüsünde 
Spanner girişini arayın 
veya "/" tuşuna basıp "Spanner" yazarak Spanner'ı arayın.
Ardından 
simgesini tıklayın ve örneğiniz için cloudspanner-leaderboard örnek adını girerek, bir yapılandırma seçerek (bölgesel bir örnek seçin) ve düğüm sayısını ayarlayarak formu doldurun. Bu codelab için yalnızca 1 düğüme ihtiyacımız olacak. Üretim örnekleri için ve Cloud Spanner HDS'sine uygun olmak üzere Cloud Spanner örneğinizde 3 veya daha fazla düğüm çalıştırmanız gerekir.
Son olarak "Oluştur"u tıkladığınızda saniyeler içinde Cloud Spanner örneğini kullanmaya başlayabilirsiniz.
Sonraki adımda, yeni örneğimizde veritabanı ve şema oluşturmak için Go istemci kitaplığını kullanacağız.
4. Veritabanı ve şema oluşturma
Bu adımda örnek veritabanımızı ve şemamızı oluşturacağız.
Oyuncu bilgileri için bir Oyuncular tablosu ve oyuncu puanlarını depolamak için bir Puanlar tablosu olmak üzere iki tablo oluşturmak için Go istemci kitaplığını kullanalım. Bunu yapmak için Cloud Shell'de Go konsol uygulaması oluşturma adımlarını inceleyeceğiz.
Öncelikle Cloud Shell'de aşağıdaki komutu yazarak bu codelab'in örnek kodunu GitHub'dan klonlayın:
export GO111MODULE=auto
go get -u github.com/GoogleCloudPlatform/golang-samples/spanner/...
Ardından, dizini uygulamanızı oluşturacağınız "leaderboard" dizini olarak değiştirin.
cd gopath/src/github.com/GoogleCloudPlatform/golang-samples/spanner/spanner_leaderboard
Bu codelab için gereken tüm kodlar, codelab'de ilerlerken referans olarak kullanabileceğiniz, golang-samples/spanner/spanner_leaderboard/adlı çalıştırılabilir bir Go uygulaması olarak mevcut leaderboard dizininde bulunur. Yeni bir dizin oluşturup skor tablosu uygulamasının bir kopyasını aşamalar halinde oluşturacağız.
Uygulama için "codelab" adlı yeni bir dizin oluşturun ve aşağıdaki komutla dizini değiştirin:
mkdir codelab && cd $_
Şimdi de Spanner istemci kitaplığını kullanarak iki tablodan oluşan bir skor tablosu oluşturmak için "Leaderboard" adlı temel bir Go uygulaması oluşturalım. Bu tablolar Players (Oyuncular) ve Scores (Skorlar) tablolarıdır. Bunu doğrudan Cloud Shell Düzenleyici'de yapabilirsiniz:
Aşağıda vurgulanan "Düzenleyiciyi aç" simgesini tıklayarak Cloud Shell Düzenleyici'yi açın:
~/gopath/src/github.com/GoogleCloudPlatform/golang-samples/spanner/codelab klasöründe "leaderboard.go" adlı bir dosya oluşturun.
- Öncelikle Cloud Shell Düzenleyici'nin klasör listesinde "codelab" klasörünün seçili olduğundan emin olun.
- Ardından, Cloud Shell Düzenleyici'nin"Dosya" menüsünden "Yeni Dosya"yı seçin.
- Yeni dosyanın adı olarak "leaderboard.go" girin.
Bu, uygulama kodumuzu ve bağımlılıkları içerecek referansları barındıracak uygulamanın ana dosyasıdır.
leaderboard veritabanını ve Players ile Scores tablolarını oluşturmak için aşağıdaki Go kodunu kopyalayıp (Ctrl + P) leaderboard.go dosyasına yapıştırın (Ctrl + V):
package main
import (
"context"
"flag"
"fmt"
"io"
"log"
"os"
"regexp"
"time"
"cloud.google.com/go/spanner"
database "cloud.google.com/go/spanner/admin/database/apiv1"
adminpb "google.golang.org/genproto/googleapis/spanner/admin/database/v1"
)
type adminCommand func(ctx context.Context, w io.Writer, adminClient *database.DatabaseAdminClient, database string) error
func createDatabase(ctx context.Context, w io.Writer, adminClient *database.DatabaseAdminClient, db string) error {
matches := regexp.MustCompile("^(.*)/databases/(.*)$").FindStringSubmatch(db)
if matches == nil || len(matches) != 3 {
return fmt.Errorf("Invalid database id %s", db)
}
op, err := adminClient.CreateDatabase(ctx, &adminpb.CreateDatabaseRequest{
Parent: matches[1],
CreateStatement: "CREATE DATABASE `" + matches[2] + "`",
ExtraStatements: []string{
`CREATE TABLE Players(
PlayerId INT64 NOT NULL,
PlayerName STRING(2048) NOT NULL
) PRIMARY KEY(PlayerId)`,
`CREATE TABLE Scores(
PlayerId INT64 NOT NULL,
Score INT64 NOT NULL,
Timestamp TIMESTAMP NOT NULL
OPTIONS(allow_commit_timestamp=true)
) PRIMARY KEY(PlayerId, Timestamp),
INTERLEAVE IN PARENT Players ON DELETE NO ACTION`,
},
})
if err != nil {
return err
}
if _, err := op.Wait(ctx); err != nil {
return err
}
fmt.Fprintf(w, "Created database [%s]\n", db)
return nil
}
func createClients(ctx context.Context, db string) (*database.DatabaseAdminClient, *spanner.Client) {
adminClient, err := database.NewDatabaseAdminClient(ctx)
if err != nil {
log.Fatal(err)
}
dataClient, err := spanner.NewClient(ctx, db)
if err != nil {
log.Fatal(err)
}
return adminClient, dataClient
}
func run(ctx context.Context, adminClient *database.DatabaseAdminClient, dataClient *spanner.Client, w io.Writer,
cmd string, db string, timespan int) error {
// createdatabase command
if cmd == "createdatabase" {
err := createDatabase(ctx, w, adminClient, db)
if err != nil {
fmt.Fprintf(w, "%s failed with %v", cmd, err)
}
return err
}
return nil
}
func main() {
flag.Usage = func() {
fmt.Fprintf(os.Stderr, `Usage: leaderboard <command> <database_name> [command_option]
Command can be one of: createdatabase
Examples:
leaderboard createdatabase projects/my-project/instances/my-instance/databases/example-db
- Create a sample Cloud Spanner database along with sample tables in your project.
`)
}
flag.Parse()
flagCount := len(flag.Args())
if flagCount != 2 {
flag.Usage()
os.Exit(2)
}
cmd, db := flag.Arg(0), flag.Arg(1)
// Set timespan to zero, as it's not currently being used
var timespan int = 0
ctx, cancel := context.WithTimeout(context.Background(), 1*time.Minute)
defer cancel()
adminClient, dataClient := createClients(ctx, db)
if err := run(ctx, adminClient, dataClient, os.Stdout, cmd, db, timespan); err != nil {
os.Exit(1)
}
}
Cloud Shell Düzenleyici'nin"Dosya" menüsünden "Kaydet"i seçerek leaderboard.go dosyasında yaptığınız değişiklikleri kaydedin.
createdatabase komutunu etkinleştirmek için kodu ekledikten sonra leaderboard.go dosyanızın nasıl görünmesi gerektiğine dair bir örnek görmek için golang-samples/spanner/spanner_leaderboard dizinindeki leaderboard.go dosyasını kullanabilirsiniz.
Uygulamanızı Cloud Shell'de derlemek için leaderboard.go dosyanızın bulunduğu codelab dizininde "go build" komutunu çalıştırın:
go build leaderboard.go
Uygulamanız başarıyla oluşturulduktan sonra aşağıdaki komutu girerek Cloud Shell'de sonuçtaki uygulamayı çalıştırın:
./leaderboard
Aşağıdakine benzer bir çıkış alırsınız:
Usage: leaderboard <command> <database_name> [command_option]
Command can be one of: createdatabase
Examples:
leaderboard createdatabase projects/my-project/instances/my-instance/databases/example-db
- Create a sample Cloud Spanner database along with sample tables in your project.
Bu yanıttan, Leaderboard uygulamasının şu anda olası bir komuta sahip olduğunu görüyoruz: createdatabase. createdatabase komutunun beklenen bağımsız değişkeninin belirli bir örnek kimliği ve veritabanı kimliği içeren bir dize olduğunu görüyoruz.
Şimdi aşağıdaki komutu çalıştırın. my-project yerine bu codelab'in başında oluşturduğunuz proje kimliğini yazdığınızdan emin olun.
./leaderboard createdatabase projects/my-project/instances/cloudspanner-leaderboard/databases/leaderboard
Birkaç saniye sonra aşağıdaki gibi bir yanıt görmeniz gerekir:
Created database [projects/my-project/instances/cloudspanner-leaderboard/databases/leaderboard]
Cloud Console'un Cloud Spanner veritabanlarına genel bakış bölümünde, sol taraftaki menüde yeni veritabanınız ve tablolarınız gösterilir.
Bir sonraki adımda, uygulamanızı yeni veritabanınıza bazı veriler yükleyecek şekilde güncelleyeceğiz.
5. Verileri Yükle
Şimdi leaderboard adlı bir veritabanımız var. Bu veritabanında Players ve Scores olmak üzere iki tablo var. Şimdi de Players tablomuzu oyuncularla, Scores tablomuzu ise her oyuncu için rastgele puanlarla doldurmak üzere Go istemci kitaplığını kullanalım.
Henüz açık değilse aşağıdaki simgeyi tıklayarak Cloud Shell Düzenleyici'yi açın:
Ardından, leaderboard.go tablosuna 100 oyuncu eklemek için kullanılabilecek bir insertplayers komutu eklemek üzere Cloud Shell Düzenleyici'de leaderboard.go dosyasını düzenleyin.Players Ayrıca, insertscores tablosundaki her oyuncu için Players tablosuna 4 rastgele puan eklemek üzere kullanılabilecek bir insertscores komutu da ekleyeceğiz.Scores
Öncelikle imports bölümünü leaderboard.go dosyasının en üstünde güncelleyin. Bu bölümdeki mevcut bilgileri, aşağıdaki gibi görünecek şekilde değiştirin:
import (
"context"
"flag"
"fmt"
"io"
"log"
"math/rand"
"os"
"regexp"
"time"
"cloud.google.com/go/spanner"
database "cloud.google.com/go/spanner/admin/database/apiv1"
"google.golang.org/api/iterator"
adminpb "google.golang.org/genproto/googleapis/spanner/admin/database/v1"
)
Ardından, dosyanın en üstünde, "type adminCommand ..." ile başlayan satırın hemen altında bir komut listesiyle birlikte yeni bir komut türü ekleyin. İşlemi tamamladığınızda dosya aşağıdaki gibi görünmelidir:
type adminCommand func(ctx context.Context, w io.Writer, adminClient *database.DatabaseAdminClient, database string) error
type command func(ctx context.Context, w io.Writer, client *spanner.Client) error
var (
commands = map[string]command{
"insertplayers": insertPlayers,
"insertscores": insertScores,
}
)
Ardından, mevcut createdatabase() işlevinin altına aşağıdaki insertPlayers ve insertScores işlevlerini ekleyin:
func insertPlayers(ctx context.Context, w io.Writer, client *spanner.Client) error {
// Get number of players to use as an incrementing value for each PlayerName to be inserted
stmt := spanner.Statement{
SQL: `SELECT Count(PlayerId) as PlayerCount FROM Players`,
}
iter := client.Single().Query(ctx, stmt)
defer iter.Stop()
row, err := iter.Next()
if err != nil {
return err
}
var numberOfPlayers int64 = 0
if err := row.Columns(&numberOfPlayers); err != nil {
return err
}
// Initialize values for random PlayerId
rand.Seed(time.Now().UnixNano())
min := 1000000000
max := 9000000000
// Insert 100 player records into the Players table
_, err = client.ReadWriteTransaction(ctx, func(ctx context.Context, txn *spanner.ReadWriteTransaction) error {
stmts := []spanner.Statement{}
for i := 1; i <= 100; i++ {
numberOfPlayers++
playerID := rand.Intn(max-min) + min
playerName := fmt.Sprintf("Player %d", numberOfPlayers)
stmts = append(stmts, spanner.Statement{
SQL: `INSERT INTO Players
(PlayerId, PlayerName)
VALUES (@playerID, @playerName)`,
Params: map[string]interface{}{
"playerID": playerID,
"playerName": playerName,
},
})
}
_, err := txn.BatchUpdate(ctx, stmts)
if err != nil {
return err
}
return nil
})
fmt.Fprintf(w, "Inserted players \n")
return nil
}
func insertScores(ctx context.Context, w io.Writer, client *spanner.Client) error {
playerRecordsFound := false
// Create slice for insert statements
stmts := []spanner.Statement{}
// Select all player records
stmt := spanner.Statement{SQL: `SELECT PlayerId FROM Players`}
iter := client.Single().Query(ctx, stmt)
defer iter.Stop()
// Insert 4 score records into the Scores table for each player in the Players table
for {
row, err := iter.Next()
if err == iterator.Done {
break
}
if err != nil {
return err
}
playerRecordsFound = true
var playerID int64
if err := row.ColumnByName("PlayerId", &playerID); err != nil {
return err
}
// Initialize values for random score and date
rand.Seed(time.Now().UnixNano())
min := 1000
max := 1000000
for i := 0; i < 4; i++ {
// Generate random score between 1,000 and 1,000,000
score := rand.Intn(max-min) + min
// Generate random day within the past two years
now := time.Now()
endDate := now.Unix()
past := now.AddDate(0, -24, 0)
startDate := past.Unix()
randomDateInSeconds := rand.Int63n(endDate-startDate) + startDate
randomDate := time.Unix(randomDateInSeconds, 0)
// Add insert statement to stmts slice
stmts = append(stmts, spanner.Statement{
SQL: `INSERT INTO Scores
(PlayerId, Score, Timestamp)
VALUES (@playerID, @score, @timestamp)`,
Params: map[string]interface{}{
"playerID": playerID,
"score": score,
"timestamp": randomDate,
},
})
}
}
if !playerRecordsFound {
fmt.Fprintln(w, "No player records currently exist. First insert players then insert scores.")
} else {
_, err := client.ReadWriteTransaction(ctx, func(ctx context.Context, txn *spanner.ReadWriteTransaction) error {
// Commit insert statements for all scores to be inserted as a single transaction
_, err := txn.BatchUpdate(ctx, stmts)
return err
})
if err != nil {
return err
}
fmt.Fprintln(w, "Inserted scores")
}
return nil
}
Ardından, insert komutunun çalışır hâle gelmesi için aşağıdaki kodu, uygulamanızın "run" işlevine createdatabase işleme ifadesinin altına ekleyin ve return nil ifadesini değiştirin :
// insert and query commands
cmdFn := commands[cmd]
if cmdFn == nil {
flag.Usage()
os.Exit(2)
}
err := cmdFn(ctx, w, dataClient)
if err != nil {
fmt.Fprintf(w, "%s failed with %v", cmd, err)
}
return err
İşlemi tamamladığınızda run işlevi aşağıdaki gibi görünmelidir:
func run(ctx context.Context, adminClient *database.DatabaseAdminClient, dataClient *spanner.Client, w io.Writer,
cmd string, db string, timespan int) error {
// createdatabase command
if cmd == "createdatabase" {
err := createDatabase(ctx, w, adminClient, db)
if err != nil {
fmt.Fprintf(w, "%s failed with %v", cmd, err)
}
return err
}
// insert and query commands
cmdFn := commands[cmd]
if cmdFn == nil {
flag.Usage()
os.Exit(2)
}
err := cmdFn(ctx, w, dataClient)
if err != nil {
fmt.Fprintf(w, "%s failed with %v", cmd, err)
}
return err
}
Uygulamanıza "insert" işlevini ekleme işlemini tamamlamak için son adım olarak flag.Usage() işlevine "insertplayers" ve "insertscores" komutları için yardım metni ekleyin. Ekleme komutlarıyla ilgili yardım metni eklemek için flag.Usage() işlevine aşağıdaki yardım metnini ekleyin:
İki komutu olası komutlar listesine ekleyin:
Command can be one of: createdatabase, insertplayers, insertscores
Ayrıca, bu ek yardım metnini createdatabase komutunun yardım metninin altına ekleyin.
leaderboard insertplayers projects/my-project/instances/my-instance/databases/example-db
- Insert 100 sample Player records into the database.
leaderboard insertscores projects/my-project/instances/my-instance/databases/example-db
- Insert sample score data into Scores sample Cloud Spanner database table.
Cloud Shell Düzenleyici'nin"Dosya" menüsünden "Kaydet"i seçerek leaderboard.go dosyasında yaptığınız değişiklikleri kaydedin.
insertplayers ve insertscores komutlarını etkinleştirmek için kodu ekledikten sonra leaderboard.go dosyanızın nasıl görünmesi gerektiğine dair bir örnek görmek için golang-samples/spanner/spanner_leaderboard dizinindeki leaderboard.go dosyasını kullanabilirsiniz.
Şimdi de yeni insertplayers ve insertscores komutlarının uygulamanın olası komutlar listesine dahil edildiğini doğrulamak için uygulamayı oluşturup çalıştıralım. Uygulamayı oluşturmak için aşağıdaki komutu çalıştırın:
go build leaderboard.go
Aşağıdaki komutu girerek Cloud Shell'de sonuçtaki uygulamayı çalıştırın:
./leaderboard
Artık uygulamanın varsayılan çıkışında insertplayers ve insertscores komutlarını görmeniz gerekir:
Usage: leaderboard <command> <database_name> [command_option]
Command can be one of: createdatabase, insertplayers, insertscores
Examples:
leaderboard createdatabase projects/my-project/instances/my-instance/databases/example-db
- Create a sample Cloud Spanner database along with sample tables in your project.
leaderboard insertplayers projects/my-project/instances/my-instance/databases/example-db
- Insert 100 sample Player records into the database.
leaderboard insertscores projects/my-project/instances/my-instance/databases/example-db
- Insert sample score data into Scores sample Cloud Spanner database table.
Şimdi insertplayers komutunu, createdatabase komutunu çağırırken kullandığımız aynı bağımsız değişken değerleriyle çalıştıralım. my-project yerine bu codelab'in başında oluşturduğunuz proje kimliğini yazdığınızdan emin olun.
./leaderboard insertplayers projects/my-project/instances/cloudspanner-leaderboard/databases/leaderboard
Birkaç saniye sonra aşağıdaki gibi bir yanıt görmeniz gerekir:
Inserted players
Şimdi de Scores tablomuzu, Players tablosundaki her oyuncu için zaman damgalarıyla birlikte dört rastgele puanla doldurmak üzere Go istemci kitaplığını kullanalım.
Scores tablosunun Timestamp sütunu, daha önce create komutunu çalıştırdığımızda yürütülen aşağıdaki SQL ifadesiyle "commit timestamp" sütunu olarak tanımlandı:
CREATE TABLE Scores(
PlayerId INT64 NOT NULL,
Score INT64 NOT NULL,
Timestamp TIMESTAMP NOT NULL OPTIONS(allow_commit_timestamp=true)
) PRIMARY KEY(PlayerId, Timestamp),
INTERLEAVE IN PARENT Players ON DELETE NO ACTION
OPTIONS(allow_commit_timestamp=true) özelliğine dikkat edin. Bu, Timestamp sütununu "commit timestamp" sütunu yapar ve belirli bir tablo satırında INSERT ve UPDATE işlemleri için tam işlem zaman damgasıyla otomatik olarak doldurulmasını sağlar.
Geçmişte bir değere sahip bir zaman damgası eklediğiniz sürece kendi zaman damgası değerlerinizi "commit timestamp" sütununa da ekleyebilirsiniz. Bu codelab'in amacı doğrultusunda bu işlemi yapacağız.
Şimdi insertscores komutunu, insertplayers komutunu çağırırken kullandığımız aynı bağımsız değişken değerleriyle çalıştıralım. my-project yerine bu codelab'in başında oluşturduğunuz proje kimliğini yazdığınızdan emin olun.
./leaderboard insertscores projects/my-project/instances/cloudspanner-leaderboard/databases/leaderboard
Birkaç saniye sonra aşağıdaki gibi bir yanıt görmeniz gerekir:
Inserted scores
insertScores işlevini çalıştırmak için, geçmişte gerçekleşen bir tarih ve saatle rastgele oluşturulmuş bir zaman damgası eklemek üzere aşağıdaki kod snippet'i kullanılır:
now := time.Now()
endDate := now.Unix()
past := now.AddDate(0, -24, 0)
startDate := past.Unix()
randomDateInSeconds := rand.Int63n(endDate-startDate) + startDate
randomDate := time.Unix(randomDateInSeconds, 0)
stmts = append(stmts, spanner.Statement{
SQL: `INSERT INTO Scores
(PlayerId, Score, Timestamp)
VALUES (@playerID, @score, @timestamp)`,
Params: map[string]interface{}{
"playerID": playerID,
"score": score,
"timestamp": randomDate,
},
})
Timestamp sütununu, "Ekle" işleminin tam olarak gerçekleştiği zaman damgasıyla otomatik olarak doldurmak için bunun yerine aşağıdaki kod snippet'inde olduğu gibi spanner.CommitTimestamp Go sabitini ekleyebilirsiniz:
...
stmts = append(stmts, spanner.Statement{
SQL: `INSERT INTO Scores
(PlayerId, Score, Timestamp)
VALUES (@playerID, @score, @timestamp)`,
Params: map[string]interface{}{
"playerID": playerID,
"score": score,
"timestamp": spanner.CommitTimestamp,
},
})
Veri yükleme işlemini tamamladığımıza göre, Cloud Console'un Cloud Spanner bölümünde yeni tablolarımıza yazdığımız değerleri doğrulayalım. Önce leaderboard veritabanını, ardından Players tablosunu seçin. Data sekmesini tıklayın. Tablonun PlayerId ve PlayerName sütunlarında verilerinizin olduğunu görmelisiniz.
Ardından, Scores tablosunu tıklayıp Data sekmesini seçerek Puanlar tablosunda da veri olup olmadığını doğrulayalım. Tablonun PlayerId, Timestamp ve Score sütunlarında verilerinizin olduğunu görmelisiniz.
Tebrikler! Oyun skor tablosu oluşturmak için kullanabileceğimiz bazı sorguları çalıştırmak üzere uygulamamızı güncelleyelim.
6. Skor tablosu sorguları çalıştırma
Veritabanımızı ayarlayıp tablolarımıza bilgi yüklediğimize göre şimdi bu verileri kullanarak bir skor tablosu oluşturalım. Bunu yapmak için aşağıdaki dört soruyu yanıtlamamız gerekiyor:
- Tüm zamanların "En İyi On" oyuncusu kimlerdir?
- Yılın "En İyi On" oyuncusu kimler?
- Ayın "En İyi On" Oyuncusu kimler?
- Haftanın "En İyi On" oyuncusu kimler?
Bu soruları yanıtlayacak SQL sorgularını çalıştırmak için uygulamamızı güncelleyelim.
Liderlik tablomuz için gereken bilgileri üretecek soruları yanıtlamak üzere sorguları çalıştırmanın bir yolunu sağlayacak query ve queryWithTimespan komutları ekleyeceğiz.
Uygulamayı query komutu ve queryWithTimespan komutu ekleyecek şekilde güncellemek için Cloud Shell Düzenleyici'de leaderboard.go dosyasını düzenleyin. Ayrıca, puanlarımızı virgülle biçimlendirmek için formatWithCommas yardımcı işlevini de ekleyeceğiz.
Öncelikle imports bölümünü leaderboard.go dosyasının en üstünde güncelleyin. Bu bölümdeki mevcut bilgileri, aşağıdaki gibi görünecek şekilde değiştirin:
import (
"bytes"
"context"
"flag"
"fmt"
"io"
"log"
"math/rand"
"os"
"regexp"
"strconv"
"time"
"cloud.google.com/go/spanner"
database "cloud.google.com/go/spanner/admin/database/apiv1"
"google.golang.org/api/iterator"
adminpb "google.golang.org/genproto/googleapis/spanner/admin/database/v1"
)
Ardından, mevcut insertScores yönteminin altına aşağıdaki iki işlevi ve yardımcı işlevi ekleyin:
func query(ctx context.Context, w io.Writer, client *spanner.Client) error {
stmt := spanner.Statement{
SQL: `SELECT p.PlayerId, p.PlayerName, s.Score, s.Timestamp
FROM Players p
JOIN Scores s ON p.PlayerId = s.PlayerId
ORDER BY s.Score DESC LIMIT 10`}
iter := client.Single().Query(ctx, stmt)
defer iter.Stop()
for {
row, err := iter.Next()
if err == iterator.Done {
return nil
}
if err != nil {
return err
}
var playerID, score int64
var playerName string
var timestamp time.Time
if err := row.Columns(&playerID, &playerName, &score, ×tamp); err != nil {
return err
}
fmt.Fprintf(w, "PlayerId: %d PlayerName: %s Score: %s Timestamp: %s\n",
playerID, playerName, formatWithCommas(score), timestamp.String()[0:10])
}
}
func queryWithTimespan(ctx context.Context, w io.Writer, client *spanner.Client, timespan int) error {
stmt := spanner.Statement{
SQL: `SELECT p.PlayerId, p.PlayerName, s.Score, s.Timestamp
FROM Players p
JOIN Scores s ON p.PlayerId = s.PlayerId
WHERE s.Timestamp > TIMESTAMP_SUB(CURRENT_TIMESTAMP(), INTERVAL @Timespan HOUR)
ORDER BY s.Score DESC LIMIT 10`,
Params: map[string]interface{}{"Timespan": timespan},
}
iter := client.Single().Query(ctx, stmt)
defer iter.Stop()
for {
row, err := iter.Next()
if err == iterator.Done {
return nil
}
if err != nil {
return err
}
var playerID, score int64
var playerName string
var timestamp time.Time
if err := row.Columns(&playerID, &playerName, &score, ×tamp); err != nil {
return err
}
fmt.Fprintf(w, "PlayerId: %d PlayerName: %s Score: %s Timestamp: %s\n",
playerID, playerName, formatWithCommas(score), timestamp.String()[0:10])
}
}
func formatWithCommas(n int64) string {
numberAsString := strconv.FormatInt(n, 10)
numberLength := len(numberAsString)
if numberLength < 4 {
return numberAsString
}
var buffer bytes.Buffer
comma := []rune(",")
bufferPosition := numberLength % 3
if (bufferPosition) > 0 {
bufferPosition = 3 - bufferPosition
}
for i := 0; i < numberLength; i++ {
if bufferPosition == 3 {
buffer.WriteRune(comma[0])
bufferPosition = 0
}
bufferPosition++
buffer.WriteByte(numberAsString[i])
}
return buffer.String()
}
Ardından, leaderboard.go dosyasının en üstünde, commands değişkeninde komut seçeneklerinden biri olarak "query" ifadesini insertscores": insertScores seçeneğinin hemen altına ekleyin. Böylece commands değişkeni şu şekilde görünür:
var (
commands = map[string]command{
"insertplayers": insertPlayers,
"insertscores": insertScores,
"query": query,
}
)
Ardından, run işlevinde, "createdatabase" komut bölümünün altında ve "insert and query" komutlarını işleme bölümünün üstünde "queryWithTimespan"ı komut seçeneği olarak ekleyin:
// querywithtimespan command
if cmd == "querywithtimespan" {
err := queryWithTimespan(ctx, w, dataClient, timespan)
if err != nil {
fmt.Fprintf(w, "%s failed with %v", cmd, err)
}
return err
}
İşlemi tamamladığınızda run işlevi aşağıdaki gibi görünmelidir:
func run(ctx context.Context, adminClient *database.DatabaseAdminClient, dataClient *spanner.Client, w io.Writer,
cmd string, db string, timespan int) error {
// createdatabase command
if cmd == "createdatabase" {
err := createDatabase(ctx, w, adminClient, db)
if err != nil {
fmt.Fprintf(w, "%s failed with %v", cmd, err)
}
return err
}
// querywithtimespan command
if cmd == "querywithtimespan" {
if timespan == 0 {
flag.Usage()
os.Exit(2)
}
err := queryWithTimespan(ctx, w, dataClient, timespan)
if err != nil {
fmt.Fprintf(w, "%s failed with %v", cmd, err)
}
return err
}
// insert and query commands
cmdFn := commands[cmd]
if cmdFn == nil {
flag.Usage()
os.Exit(2)
}
err := cmdFn(ctx, w, dataClient)
if err != nil {
fmt.Fprintf(w, "%s failed with %v", cmd, err)
}
return err
}
Ardından, queryWithTimespan komutunun çalışır hale gelmesi için uygulamanızın "main" yöntemindeki flag.Parse() kod bloğunu aşağıdaki gibi görünecek şekilde güncelleyin:
flag.Parse()
flagCount := len(flag.Args())
if flagCount < 2 || flagCount > 3 {
flag.Usage()
os.Exit(2)
}
cmd, db := flag.Arg(0), flag.Arg(1)
// If query timespan flag is specified, parse to int
var timespan int = 0
if flagCount == 3 {
parsedTimespan, err := strconv.Atoi(flag.Arg(2))
if err != nil {
fmt.Println(err)
os.Exit(2)
}
timespan = parsedTimespan
}
ctx, cancel := context.WithTimeout(context.Background(), 1*time.Minute)
defer cancel()
adminClient, dataClient := createClients(ctx, db)
if err := run(ctx, adminClient, dataClient, os.Stdout, cmd, db, timespan); err != nil {
os.Exit(1)
}
Uygulamanıza "sorgu" işlevini eklemeyi tamamlamak için son adım olarak flag.Usage() işlevine "sorgu" ve "querywithtimespan" komutları için yardım metni ekleyin. Sorgu komutlarıyla ilgili yardım metni eklemek için flag.Usage() işlevine aşağıdaki kod satırlarını ekleyin:
Olası komutlar listesine iki "sorgu" komutunu ekleyin:
Command can be one of: createdatabase, insertplayers, insertscores, query, querywithtimespan
Ayrıca, bu ek yardım metnini insertscores komutunun yardım metninin altına ekleyin.
leaderboard query projects/my-project/instances/my-instance/databases/example-db
- Query players with top ten scores of all time.
leaderboard querywithtimespan projects/my-project/instances/my-instance/databases/example-db 168
- Query players with top ten scores within a timespan specified in hours.
Cloud Shell Düzenleyici'nin"Dosya" menüsünden "Kaydet"i seçerek leaderboard.go dosyasında yaptığınız değişiklikleri kaydedin.
query ve querywithtimespan komutlarını etkinleştirmek için kodu ekledikten sonra leaderboard.go dosyanızın nasıl görünmesi gerektiğine dair bir örnek görmek için golang-samples/spanner/spanner_leaderboard dizinindeki leaderboard.go dosyasını kullanabilirsiniz.
Şimdi de yeni query ve querywithtimespan komutlarının uygulamanın olası komutlar listesine dahil edildiğini doğrulamak için uygulamayı oluşturup çalıştıralım.
Uygulamayı oluşturmak için Cloud Shell'de aşağıdaki komutu çalıştırın:
go build leaderboard.go
Aşağıdaki komutu girerek Cloud Shell'de sonuçtaki uygulamayı çalıştırın:
./leaderboard
query ve querywithtimespan komutlarının, uygulamanın varsayılan çıkışına yeni bir komut seçeneği olarak eklendiğini görürsünüz:
Usage: leaderboard <command> <database_name> [command_option]
Command can be one of: createdatabase, insertplayers, insertscores, query, querywithtimespan
Examples:
leaderboard createdatabase projects/my-project/instances/my-instance/databases/example-db
- Create a sample Cloud Spanner database along with sample tables in your project.
leaderboard insertplayers projects/my-project/instances/my-instance/databases/example-db
- Insert 100 sample Player records into the database.
leaderboard insertscores projects/my-project/instances/my-instance/databases/example-db
- Insert sample score data into Scores sample Cloud Spanner database table.
leaderboard query projects/my-project/instances/my-instance/databases/example-db
- Query players with top ten scores of all time.
leaderboard querywithtimespan projects/my-project/instances/my-instance/databases/example-db 168
- Query players with top ten scores within a timespan specified in hours.
Yanıtı incelediğimizde, tüm zamanların "En İyi On" oyuncusunun listesini almak için query komutunu kullanabileceğimizi görüyoruz. Ayrıca, querywithtimespan komutunun, kayıtları Scores tablosunun Timestamp sütunundaki değerlerine göre filtrelemek için kullanılacak zaman aralığını saat cinsinden belirtmemize olanak tanıdığını da görüyoruz.
query komutunu, create komutunu çalıştırırken kullandığımız bağımsız değişken değerleriyle çalıştıralım. my-project yerine bu codelab'in başında oluşturduğunuz proje kimliğini yazdığınızdan emin olun.
./leaderboard query projects/my-project/instances/cloudspanner-leaderboard/databases/leaderboard
Aşağıdaki gibi, tüm zamanların "En İyi On" oyuncusunu içeren bir yanıt görmelisiniz:
PlayerId: 4018687297 PlayerName: Player 83 Score: 999,618 Timestamp: 2017-07-01
PlayerId: 4018687297 PlayerName: Player 83 Score: 998,956 Timestamp: 2017-09-02
PlayerId: 4285713246 PlayerName: Player 51 Score: 998,648 Timestamp: 2017-12-01
PlayerId: 5267931774 PlayerName: Player 49 Score: 997,733 Timestamp: 2017-11-09
PlayerId: 1981654448 PlayerName: Player 35 Score: 997,480 Timestamp: 2018-12-06
PlayerId: 4953940705 PlayerName: Player 87 Score: 995,184 Timestamp: 2018-09-14
PlayerId: 2456736905 PlayerName: Player 84 Score: 992,881 Timestamp: 2017-04-14
PlayerId: 8234617611 PlayerName: Player 19 Score: 992,399 Timestamp: 2017-12-27
PlayerId: 1788051688 PlayerName: Player 76 Score: 992,265 Timestamp: 2018-11-22
PlayerId: 7127686505 PlayerName: Player 97 Score: 992,038 Timestamp: 2017-12-02
Şimdi de bir yılın saat sayısına (8.760) eşit bir "zaman aralığı" belirterek yılın "En İyi On" oyuncusunu sorgulamak için gerekli bağımsız değişkenlerle querywithtimespan komutunu çalıştıralım. my-project yerine bu codelab'in başında oluşturduğunuz proje kimliğini yazdığınızdan emin olun.
./leaderboard querywithtimespan projects/my-project/instances/cloudspanner-leaderboard/databases/leaderboard 8760
Aşağıdaki gibi, yılın "En İyi On" oyuncusunu içeren bir yanıt görürsünüz:
PlayerId: 1981654448 PlayerName: Player 35 Score: 997,480 Timestamp: 2018-12-06
PlayerId: 4953940705 PlayerName: Player 87 Score: 995,184 Timestamp: 2018-09-14
PlayerId: 1788051688 PlayerName: Player 76 Score: 992,265 Timestamp: 2018-11-22
PlayerId: 6862349579 PlayerName: Player 30 Score: 990,877 Timestamp: 2018-09-14
PlayerId: 5529627211 PlayerName: Player 16 Score: 989,142 Timestamp: 2018-03-30
PlayerId: 9743904155 PlayerName: Player 1 Score: 988,765 Timestamp: 2018-05-30
PlayerId: 6809119884 PlayerName: Player 7 Score: 986,673 Timestamp: 2018-05-16
PlayerId: 2132710638 PlayerName: Player 54 Score: 983,108 Timestamp: 2018-09-11
PlayerId: 2320093590 PlayerName: Player 79 Score: 981,373 Timestamp: 2018-05-07
PlayerId: 9554181430 PlayerName: Player 80 Score: 981,087 Timestamp: 2018-06-21
Şimdi de bir ayın saat sayısına (730) eşit bir "zaman aralığı" belirterek ayın "En İyi On" oyuncusunu sorgulamak için querywithtimespan komutunu çalıştıralım. my-project yerine bu codelab'in başında oluşturduğunuz proje kimliğini yazdığınızdan emin olun.
./leaderboard querywithtimespan projects/my-project/instances/cloudspanner-leaderboard/databases/leaderboard 730
Aşağıdaki gibi, ayın "En İyi On" oyuncusunu içeren bir yanıt görürsünüz:
PlayerId: 3869829195 PlayerName: Player 69 Score: 949,686 Timestamp: 2019-02-19
PlayerId: 7448359883 PlayerName: Player 20 Score: 938,998 Timestamp: 2019-02-07
PlayerId: 1981654448 PlayerName: Player 35 Score: 929,003 Timestamp: 2019-02-22
PlayerId: 9336678658 PlayerName: Player 44 Score: 914,106 Timestamp: 2019-01-27
PlayerId: 6968576389 PlayerName: Player 40 Score: 898,041 Timestamp: 2019-02-21
PlayerId: 5529627211 PlayerName: Player 16 Score: 896,433 Timestamp: 2019-01-29
PlayerId: 9395039625 PlayerName: Player 59 Score: 879,495 Timestamp: 2019-02-09
PlayerId: 2094604854 PlayerName: Player 39 Score: 860,434 Timestamp: 2019-02-01
PlayerId: 9395039625 PlayerName: Player 59 Score: 849,955 Timestamp: 2019-02-21
PlayerId: 4285713246 PlayerName: Player 51 Score: 805,654 Timestamp: 2019-02-02
Şimdi de haftanın "En İyi On" oyuncusunu sorgulamak için querywithtimespan komutunu çalıştıralım. Bunu yaparken bir haftadaki saat sayısına (168) eşit bir "zaman aralığı" belirteceğiz. my-project yerine bu codelab'in başında oluşturduğunuz proje kimliğini yazdığınızdan emin olun.
./leaderboard querywithtimespan projects/my-project/instances/cloudspanner-leaderboard/databases/leaderboard 168
Aşağıdaki gibi, haftanın "En İyi On" oyuncusunu içeren bir yanıt görürsünüz:
PlayerId: 3869829195 PlayerName: Player 69 Score: 949,686 Timestamp: 2019-02-19
PlayerId: 1981654448 PlayerName: Player 35 Score: 929,003 Timestamp: 2019-02-22
PlayerId: 6968576389 PlayerName: Player 40 Score: 898,041 Timestamp: 2019-02-21
PlayerId: 9395039625 PlayerName: Player 59 Score: 849,955 Timestamp: 2019-02-21
PlayerId: 5954045812 PlayerName: Player 8 Score: 795,639 Timestamp: 2019-02-22
PlayerId: 3889939638 PlayerName: Player 71 Score: 775,252 Timestamp: 2019-02-21
PlayerId: 5529627211 PlayerName: Player 16 Score: 604,695 Timestamp: 2019-02-19
PlayerId: 9006728426 PlayerName: Player 3 Score: 457,208 Timestamp: 2019-02-22
PlayerId: 8289497066 PlayerName: Player 58 Score: 227,697 Timestamp: 2019-02-20
PlayerId: 8065482904 PlayerName: Player 99 Score: 198,429 Timestamp: 2019-02-24
Harika!
Artık kayıt ekledikçe Cloud Spanner, veritabanınızı ihtiyacınız olan boyuta göre ölçeklendirir. Veritabanınız ne kadar büyürse büyüsün, Cloud Spanner ve Truetime teknolojisi sayesinde oyununuzun skor tablosu doğru bir şekilde ölçeklenmeye devam edebilir.
7. Temizleme
Spanner ile oynayarak eğlendikten sonra, değerli kaynakları ve parayı korumak için oyun alanımızı temizlememiz gerekir. Neyse ki bu kolay bir adım. Cloud Console'un Cloud Spanner bölümüne gidip "Setup a Cloud Spanner Instance" (Cloud Spanner örneği oluşturma) adlı codelab adımında oluşturduğumuz örneği silmeniz yeterli.
8. Tebrikler!
İşlediğimiz konular:
- Liderlik tablosu için Google Cloud Spanner örnekleri, veritabanları ve tablo şeması
- Go konsol uygulaması oluşturma
- Go istemci kitaplığını kullanarak Spanner veritabanı ve tabloları oluşturma
- Go istemci kitaplığını kullanarak Spanner veritabanına veri yükleme
- Spanner commit zaman damgalarını ve Go istemci kitaplığını kullanarak verilerinizdeki "İlk On" sonuçlarını sorgulama
Sonraki Adımlar:
- Spanner CAP Teknik Belgesi'ni okuyun.
- Şema tasarımı ve sorgu ile ilgili en iyi uygulamalar hakkında bilgi edinin.
- Cloud Spanner işleme zaman damgaları hakkında daha fazla bilgi edinin.
Görüşlerinizi bizimle paylaşın
- Lütfen birkaç dakikanızı ayırarak çok kısa anketimizi doldurun.