1. Omówienie
Google Cloud Spanner to w pełni zarządzana, skalowalna w poziomie, rozproszona globalnie, relacyjna usługa baz danych, która zapewnia transakcje ACID i semantykę SQL bez utraty wydajności i wysokiej dostępności.
W tym module dowiesz się, jak skonfigurować instancję Cloud Spanner. Wykonasz kolejne kroki tworzenia bazy danych i schematu, które będą służyć do tworzenia tabeli wyników w grach. Na początek utwórz tabelę zawodników, w której będą przechowywane informacje o graczach, oraz tabelę wyników, by zapisać wyniki.
Następnie wypełnij tabele przykładowymi danymi. Następnie na koniec modułu uruchomisz kilka przykładowych zapytań o 10 najczęstszych pytań i usuniesz instancję, aby zwolnić zasoby.
Czego się nauczysz
- Jak skonfigurować instancję Cloud Spanner.
- Jak utworzyć bazę danych i tabele.
- Jak używać kolumny z sygnaturą czasową zatwierdzenia.
- Jak wczytywać dane do tabeli bazy danych Cloud Spanner z sygnaturami czasowymi.
- Jak wysyłać zapytania do bazy danych Cloud Spanner.
- Jak usunąć instancję Cloud Spanner.
Co będzie Ci potrzebne
Jak wykorzystasz ten samouczek?
Jak oceniasz swoje doświadczenia z Google Cloud Platform?
2. Konfiguracja i wymagania
Samodzielne konfigurowanie środowiska
Jeśli nie masz jeszcze konta Google (w Gmailu lub Google Apps), musisz je utworzyć. Zaloguj się w konsoli Google Cloud Platform ( console.cloud.google.com) i utwórz nowy projekt.
Jeśli masz już projekt, kliknij menu wyboru projektu w lewym górnym rogu konsoli:
i kliknij „NOWY PROJEKT”. w wyświetlonym oknie, aby utworzyć nowy projekt:
Jeśli nie masz jeszcze projektu, zobaczysz takie okno dialogowe umożliwiające utworzenie pierwszego:
W kolejnym oknie tworzenia projektu możesz wpisać szczegóły nowego projektu:
Zapamiętaj identyfikator projektu, który jest niepowtarzalną nazwą we wszystkich projektach Google Cloud (powyższa nazwa jest już zajęta i nie będzie Ci odpowiadać). W dalszej części tego ćwiczenia w programie będzie ona określana jako PROJECT_ID.
Następnie musisz włączyć płatności w Developers Console, aby korzystać z zasobów Google Cloud i włączyć interfejs Cloud Spanner API.
Ukończenie tego ćwiczenia w Codelabs nie powinno kosztować więcej niż kilka dolarów, ale może być droższe, jeśli zdecydujesz się użyć więcej zasobów lub nie chcesz ich uruchamiać (patrz sekcja „Czyszczenie” na końcu tego dokumentu). Cennik Google Cloud Spanner znajdziesz tutaj.
Nowi użytkownicy Google Cloud Platform mogą skorzystać z bezpłatnego okresu próbnego w wysokości 300 USD, dzięki czemu te ćwiczenia z programowania są całkowicie bezpłatne.
Konfiguracja Google Cloud Shell
Usługi Google Cloud i Spanner można obsługiwać zdalnie z poziomu laptopa, ale w ramach tego ćwiczenia w programowaniu użyjemy Google Cloud Shell – środowiska wiersza poleceń działającego w chmurze.
Ta maszyna wirtualna oparta na Debianie zawiera wszystkie potrzebne narzędzia dla programistów. Zawiera stały katalog domowy o pojemności 5 GB i działa w Google Cloud, co znacznie zwiększa wydajność sieci i uwierzytelnianie. Oznacza to, że do tego ćwiczenia z programowania wystarczy przeglądarka (tak, działa ona na Chromebooku).
- Aby aktywować Cloud Shell z poziomu konsoli Cloud, kliknij Aktywuj Cloud Shell
(udostępnienie środowiska i połączenie z nim powinno zająć tylko chwilę).
Po nawiązaniu połączenia z Cloud Shell powinno pojawić się potwierdzenie, że użytkownik jest już uwierzytelniony, a projekt jest już ustawiony na PROJECT_ID.
gcloud auth list
Dane wyjściowe polecenia
Credentialed accounts: - <myaccount>@<mydomain>.com (active)
gcloud config list project
Dane wyjściowe polecenia
[core] project = <PROJECT_ID>
Jeśli z jakiegoś powodu projekt nie jest skonfigurowany, uruchom po prostu to polecenie:
gcloud config set project <PROJECT_ID>
Szukasz urządzenia PROJECT_ID? Sprawdź identyfikator użyty w krokach konfiguracji lub wyszukaj go w panelu Cloud Console:
Cloud Shell ustawia też domyślnie niektóre zmienne środowiskowe, które mogą być przydatne podczas uruchamiania kolejnych poleceń.
echo $GOOGLE_CLOUD_PROJECT
Dane wyjściowe polecenia
<PROJECT_ID>
- Na koniec ustaw domyślną strefę i konfigurację projektu.
gcloud config set compute/zone us-central1-f
Możesz wybrać różne strefy. Więcej informacji znajdziesz w artykule Regiony i Strefy.
Podsumowanie
W tym kroku skonfigurujesz środowisko.
Dalsze czynności
Następnie skonfigurujesz instancję Cloud Spanner.
3. Konfigurowanie instancji Cloud Spanner
W tym kroku skonfigurujemy instancję Cloud Spanner na potrzeby tego ćwiczenia w Codelabs. Wyszukaj pozycję Spannera 
w menu Hamburger po lewej stronie 
lub wyszukaj usługę Spanner, naciskając „/” i wpisz „Spanner”
Następnie kliknij 
i wypełnij formularz, wpisując nazwę instancji cloudspanner-leaderboard dla swojej instancji, wybierając konfigurację (wybierz instancję regionalną) i ustaw liczbę węzłów. Do tego ćwiczenia w Codelabs potrzebujemy tylko 1 węzła. Aby korzystać z instancji produkcyjnych i kwalifikować się do gwarancji jakości usług Cloud Spanner, w instancji Cloud Spanner musisz mieć co najmniej 3 węzły.
Kliknij „Utwórz”. a w ciągu kilku sekund będziesz mieć do dyspozycji instancję Cloud Spanner.
W następnym kroku użyjemy biblioteki klienta w języku C# do utworzenia bazy danych i schematu w naszej nowej instancji.
4. Tworzenie bazy danych i schematu
W tym kroku utworzymy naszą przykładową bazę danych i schemat.
Utwórzmy 2 tabele za pomocą biblioteki klienta w języku C#. tabela zawodników z informacjami o graczach i tabela wyników, w której są przechowywane ich wyniki. Przeprowadzimy Cię przez proces tworzenia aplikacji konsoli C# w Cloud Shell.
Najpierw skopiuj z GitHub przykładowy kod tego ćwiczenia z programowania, wpisując w Cloud Shell to polecenie:
git clone https://github.com/GoogleCloudPlatform/dotnet-docs-samples.git
Następnie zmień katalog na „applications”. w którym utworzysz aplikację.
cd dotnet-docs-samples/applications/
Cały kod wymagany w tym ćwiczeniu w Codelabs znajduje się w istniejącym katalogu dotnet-docs-samples/applications/leaderboard jako uruchamiana aplikacja w języku C# o nazwie Leaderboard, która będzie służyć jako wzorzec. Utworzymy nowy katalog i etapami utworzymy kopię aplikacji Tabela wyników.
Utwórz nowy katalog o nazwie „codelab” dla aplikacji i zmień na nią katalog za pomocą tego polecenia:
mkdir codelab && cd $_
Utwórz nową aplikację konsoli .NET C# o nazwie „Długi baner” za pomocą tego polecenia:
dotnet new console -n Leaderboard
To polecenie tworzy prostą aplikację konsoli składającą się z 2 plików podstawowych – pliku projektu Leaderboard.csproj i pliku programu Program.cs.
Do dzieła. Przejdź do nowo utworzonego katalogu Tabela wyników, w którym znajduje się aplikacja:
cd Leaderboard
Następnie wpisz to polecenie, aby je uruchomić.
dotnet run
Powinny się wyświetlić dane wyjściowe aplikacji „Hello World”.
Teraz zaktualizujmy aplikację konsolową, edytując Program.cs tak, aby użyć biblioteki klienta C# Spannera do utworzenia tabeli wyników z 2 tabelami: odtwarzaczami i wynikami. Możesz to zrobić w edytorze Cloud Shell:
Otwórz edytor Cloud Shell, klikając podświetloną ikonę:
Następnie otwórz plik Program.cs w edytorze Cloud Shell i zastąp istniejący kod pliku kodem wymaganym do utworzenia bazy danych leaderboard oraz tabel Players i Scores. W tym celu wklej ten kod aplikacji w języku C# w pliku Program.cs:
using System;
using System.Threading.Tasks;
using Google.Cloud.Spanner.Data;
using CommandLine;
namespace GoogleCloudSamples.Leaderboard
{
[Verb("create", HelpText = "Create a sample Cloud Spanner database "
+ "along with sample 'Players' and 'Scores' tables in your project.")]
class CreateOptions
{
[Value(0, HelpText = "The project ID of the project to use "
+ "when creating Cloud Spanner resources.", Required = true)]
public string projectId { get; set; }
[Value(1, HelpText = "The ID of the instance where the sample database "
+ "will be created.", Required = true)]
public string instanceId { get; set; }
[Value(2, HelpText = "The ID of the sample database to create.",
Required = true)]
public string databaseId { get; set; }
}
public class Program
{
enum ExitCode : int
{
Success = 0,
InvalidParameter = 1,
}
public static object Create(string projectId,
string instanceId, string databaseId)
{
var response =
CreateAsync(projectId, instanceId, databaseId);
Console.WriteLine("Waiting for operation to complete...");
response.Wait();
Console.WriteLine($"Operation status: {response.Status}");
Console.WriteLine($"Created sample database {databaseId} on "
+ $"instance {instanceId}");
return ExitCode.Success;
}
public static async Task CreateAsync(
string projectId, string instanceId, string databaseId)
{
// Initialize request connection string for database creation.
string connectionString =
$"Data Source=projects/{projectId}/instances/{instanceId}";
using (var connection = new SpannerConnection(connectionString))
{
string createStatement = $"CREATE DATABASE `{databaseId}`";
string[] createTableStatements = new string[] {
// Define create table statement for Players table.
@"CREATE TABLE Players(
PlayerId INT64 NOT NULL,
PlayerName STRING(2048) NOT NULL
) PRIMARY KEY(PlayerId)",
// Define create table statement for Scores table.
@"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" };
// Make the request.
var cmd = connection.CreateDdlCommand(
createStatement, createTableStatements);
try
{
await cmd.ExecuteNonQueryAsync();
}
catch (SpannerException e) when
(e.ErrorCode == ErrorCode.AlreadyExists)
{
// OK.
}
}
}
public static int Main(string[] args)
{
var verbMap = new VerbMap<object>();
verbMap
.Add((CreateOptions opts) => Create(
opts.projectId, opts.instanceId, opts.databaseId))
.NotParsedFunc = (err) => 1;
return (int)verbMap.Run(args);
}
}
}
Aby lepiej zrozumieć kod programu, przedstawiamy schemat z jego głównymi elementami oznaczonymi etykietami:
Aby zobaczyć przykładowy wygląd pliku Program.cs po dodaniu kodu włączającego polecenie create, możesz użyć pliku Program.cs z katalogu dotnet-docs-samples/applications/leaderboard/step4.
Następnie w edytorze Cloud Shell otwórz i zmodyfikuj plik projektu programu Leaderboard.csproj, aktualizując go tak, aby wyglądał jak poniższy kod. Zapisz wszystkie zmiany, korzystając z pola „Plik” w menu edytora Cloud Shell.
<Project Sdk="Microsoft.NET.Sdk">
<PropertyGroup>
<OutputType>Exe</OutputType>
<TargetFramework>netcoreapp3.1</TargetFramework>
</PropertyGroup>
<ItemGroup>
<PackageReference Include="Google.Cloud.Spanner.Data" Version="3.3.0" />
</ItemGroup>
<ItemGroup>
<ProjectReference Include="..\..\..\commandlineutil\Lib\CommandLineUtil.csproj" />
</ItemGroup>
</Project>
Ta zmiana dodała odwołanie do pakietu Google.Cloud.Spanner.Data Spanner Nuget, którego musimy używać z interfejsem Cloud Spanner API. Ta zmiana dodaje też odwołanie do projektu CommandLineUtil, który jest częścią repozytorium dotnet-doc-samples GitHub i udostępnia przydatną „verbmap” rozszerzenie do oprogramowania typu open source CommandLineParser; przydatna biblioteka do obsługi danych wejściowych z wiersza poleceń dla aplikacji konsolowych.
Aby zobaczyć przykładowy wygląd pliku Leaderboard.csproj po dodaniu kodu włączającego polecenie create, możesz użyć pliku Leaderboard.csproj z katalogu dotnet-docs-samples/applications/leaderboard/step4.
Teraz możesz uruchomić zaktualizowany fragment. Wpisz następujące polecenie, aby wyświetlić domyślną odpowiedź zaktualizowanej aplikacji:
dotnet run
Zostaną wyświetlone dane wyjściowe podobne do tych:
Leaderboard 1.0.0 Copyright (C) 2018 Leaderboard ERROR(S): No verb selected. create Create a sample Cloud Spanner database along with sample 'Players' and 'Scores' tables in your project. help Display more information on a specific command. version Display version information.
Na podstawie tej odpowiedzi widzimy, że jest to aplikacja Leaderboard, którą można uruchomić przy użyciu jednego z 3 możliwych poleceń: create, help lub version.
Przetestujmy polecenie create, aby utworzyć bazę danych i tabele Spannera. Uruchom polecenie bez argumentów, aby wyświetlić oczekiwane argumenty polecenia.
dotnet run create
Powinna pojawić się odpowiedź podobna do tej:
Leaderboard 1.0.0 Copyright (C) 2018 Leaderboard ERROR(S): A required value not bound to option name is missing. --help Display this help screen. --version Display version information. value pos. 0 Required. The project ID of the project to use when creating Cloud Spanner resources. value pos. 1 Required. The ID of the instance where the sample database will be created. value pos. 2 Required. The ID of the sample database to create.
Jak widać, oczekiwane argumenty polecenia create to identyfikator projektu, identyfikator instancji oraz identyfikator bazy danych.
Teraz uruchom następujące polecenie. Pamiętaj, aby zastąpić PROJECT_ID identyfikatorem projektu utworzonym na początku tego ćwiczenia.
dotnet run create PROJECT_ID cloudspanner-leaderboard leaderboard
Po kilku sekundach powinna pojawić się taka odpowiedź:
Waiting for operation to complete... Operation status: RanToCompletion Created sample database leaderboard on instance cloudspanner-leaderboard
W sekcji Cloud Spanner konsoli Cloud powinna pojawić się nowa baza danych i tabele w menu po lewej stronie.
W następnym kroku zaktualizujemy naszą aplikację, aby wczytywała część danych do Twojej nowej bazy danych.
5. Wczytaj dane
Mamy teraz bazę danych o nazwie leaderboard, która zawiera 2 tabele; Players i Scores. Teraz użyjemy biblioteki klienta w języku C#, aby wypełnić tabelę Players graczami, a tabelę Scores losowymi wynikami każdego z nich.
Otwórz edytor Cloud Shell, klikając podświetloną ikonę:
Następnie zmodyfikuj plik Program.cs w edytorze Cloud Shell, dodając polecenie insert, które umożliwia wstawienie 100 odtwarzaczy do tabeli Players lub pozwala wstawić 4 losowe wyniki w tabeli Scores każdego gracza w tabeli Players.
Najpierw dodaj nowy blok poleceń insert w interfejsie „Verbmap” w górnej części Programu, pod istniejącym blokiem poleceń create:
[Verb("insert", HelpText = "Insert sample 'players' records or 'scores' records "
+ "into the database.")]
class InsertOptions
{
[Value(0, HelpText = "The project ID of the project to use "
+ "when managing Cloud Spanner resources.", Required = true)]
public string projectId { get; set; }
[Value(1, HelpText = "The ID of the instance where the sample database resides.",
Required = true)]
public string instanceId { get; set; }
[Value(2, HelpText = "The ID of the database where the sample database resides.",
Required = true)]
public string databaseId { get; set; }
[Value(3, HelpText = "The type of insert to perform, 'players' or 'scores'.",
Required = true)]
public string insertType { get; set; }
}
Następnie dodaj metody Insert, InsertPlayersAsync i InsertScoresAsync pod istniejącą metodą CreateAsync:
public static object Insert(string projectId,
string instanceId, string databaseId, string insertType)
{
if (insertType.ToLower() == "players")
{
var responseTask =
InsertPlayersAsync(projectId, instanceId, databaseId);
Console.WriteLine("Waiting for insert players operation to complete...");
responseTask.Wait();
Console.WriteLine($"Operation status: {responseTask.Status}");
}
else if (insertType.ToLower() == "scores")
{
var responseTask =
InsertScoresAsync(projectId, instanceId, databaseId);
Console.WriteLine("Waiting for insert scores operation to complete...");
responseTask.Wait();
Console.WriteLine($"Operation status: {responseTask.Status}");
}
else
{
Console.WriteLine("Invalid value for 'type of insert'. "
+ "Specify 'players' or 'scores'.");
return ExitCode.InvalidParameter;
}
Console.WriteLine($"Inserted {insertType} into sample database "
+ $"{databaseId} on instance {instanceId}");
return ExitCode.Success;
}
public static async Task InsertPlayersAsync(string projectId,
string instanceId, string databaseId)
{
string connectionString =
$"Data Source=projects/{projectId}/instances/{instanceId}"
+ $"/databases/{databaseId}";
long numberOfPlayers = 0;
using (var connection = new SpannerConnection(connectionString))
{
await connection.OpenAsync();
await connection.RunWithRetriableTransactionAsync(async (transaction) =>
{
// Execute a SQL statement to get current number of records
// in the Players table to use as an incrementing value
// for each PlayerName to be inserted.
var cmd = connection.CreateSelectCommand(
@"SELECT Count(PlayerId) as PlayerCount FROM Players");
numberOfPlayers = await cmd.ExecuteScalarAsync<long>();
// Insert 100 player records into the Players table.
SpannerBatchCommand cmdBatch = connection.CreateBatchDmlCommand();
for (int i = 0; i < 100; i++)
{
numberOfPlayers++;
SpannerCommand cmdInsert = connection.CreateDmlCommand(
"INSERT INTO Players "
+ "(PlayerId, PlayerName) "
+ "VALUES (@PlayerId, @PlayerName)",
new SpannerParameterCollection {
{"PlayerId", SpannerDbType.Int64},
{"PlayerName", SpannerDbType.String}});
cmdInsert.Parameters["PlayerId"].Value =
Math.Abs(Guid.NewGuid().GetHashCode());
cmdInsert.Parameters["PlayerName"].Value =
$"Player {numberOfPlayers}";
cmdBatch.Add(cmdInsert);
}
await cmdBatch.ExecuteNonQueryAsync();
});
}
Console.WriteLine("Done inserting player records...");
}
public static async Task InsertScoresAsync(
string projectId, string instanceId, string databaseId)
{
string connectionString =
$"Data Source=projects/{projectId}/instances/{instanceId}"
+ $"/databases/{databaseId}";
// Insert 4 score records into the Scores table for each player
// in the Players table.
using (var connection = new SpannerConnection(connectionString))
{
await connection.OpenAsync();
await connection.RunWithRetriableTransactionAsync(async (transaction) =>
{
Random r = new Random();
bool playerRecordsFound = false;
SpannerBatchCommand cmdBatch =
connection.CreateBatchDmlCommand();
var cmdLookup =
connection.CreateSelectCommand("SELECT * FROM Players");
using (var reader = await cmdLookup.ExecuteReaderAsync())
{
while (await reader.ReadAsync())
{
playerRecordsFound = true;
for (int i = 0; i < 4; i++)
{
DateTime randomTimestamp = DateTime.Now
.AddYears(r.Next(-2, 1))
.AddMonths(r.Next(-12, 1))
.AddDays(r.Next(-28, 0))
.AddHours(r.Next(-24, 0))
.AddSeconds(r.Next(-60, 0))
.AddMilliseconds(r.Next(-100000, 0));
SpannerCommand cmdInsert =
connection.CreateDmlCommand(
"INSERT INTO Scores "
+ "(PlayerId, Score, Timestamp) "
+ "VALUES (@PlayerId, @Score, @Timestamp)",
new SpannerParameterCollection {
{"PlayerId", SpannerDbType.Int64},
{"Score", SpannerDbType.Int64},
{"Timestamp",
SpannerDbType.Timestamp}});
cmdInsert.Parameters["PlayerId"].Value =
reader.GetFieldValue<int>("PlayerId");
cmdInsert.Parameters["Score"].Value =
r.Next(1000, 1000001);
cmdInsert.Parameters["Timestamp"].Value =
randomTimestamp.ToString("o");
cmdBatch.Add(cmdInsert);
}
}
if (!playerRecordsFound)
{
Console.WriteLine("Parameter 'scores' is invalid "
+ "since no player records currently exist. First "
+ "insert players then insert scores.");
Environment.Exit((int)ExitCode.InvalidParameter);
}
else
{
await cmdBatch.ExecuteNonQueryAsync();
Console.WriteLine(
"Done inserting score records..."
);
}
}
});
}
}
Następnie, aby polecenie insert działało, dodaj poniższy kod do sekcji „Main” (Główny) programu. :
.Add((InsertOptions opts) => Insert(
opts.projectId, opts.instanceId, opts.databaseId, opts.insertType))
Aby zobaczyć przykładowy wygląd pliku Program.cs po dodaniu kodu włączającego polecenie insert, możesz użyć pliku Program.cs z katalogu dotnet-docs-samples/applications/leaderboard/step5.
Teraz uruchom program, aby sprawdzić, czy nowe polecenie insert znajduje się na liście możliwych poleceń programu. Uruchom to polecenie:
dotnet run
Polecenie insert powinno pojawić się w domyślnych danych wyjściowych programu:
Leaderboard 1.0.0 Copyright (C) 2018 Leaderboard ERROR(S): No verb selected. create Create a sample Cloud Spanner database along with sample 'Players' and 'Scores' tables in your project. insert Insert sample 'players' records or 'scores' records into the database. help Display more information on a specific command. version Display version information.
Teraz uruchom polecenie insert, aby zobaczyć argumenty wejściowe. Wpisz następujące polecenie.
dotnet run insert
Powinno to zwrócić taką odpowiedź:
Leaderboard 1.0.0 Copyright (C) 2018 Leaderboard ERROR(S): A required value not bound to option name is missing. --help Display this help screen. --version Display version information. value pos. 0 Required. The project ID of the project to use when managing Cloud Spanner resources. value pos. 1 Required. The ID of the instance where the sample database resides. value pos. 2 Required. The ID of the database where the sample database resides. value pos. 3 Required. The type of insert to perform, 'players' or 'scores'.
Z odpowiedzi wynika, że oprócz identyfikatora projektu, identyfikatora instancji oraz identyfikatora bazy danych jest jeszcze inny argument value pos. 3, który jest „typem insert” do wykonania. Ten argument może mieć wartość „gracze” czyli „wyniki”.
Teraz uruchom polecenie insert z tymi samymi wartościami argumentów, które użyliśmy przy wywołaniu polecenia create, dodając „players” jako dodatkowy „typ wstawiania”, . Pamiętaj, aby zastąpić PROJECT_ID identyfikatorem projektu utworzonym na początku tego ćwiczenia.
dotnet run insert PROJECT_ID cloudspanner-leaderboard leaderboard players
Po kilku sekundach powinna pojawić się taka odpowiedź:
Waiting for insert players operation to complete... Done inserting player records... Operation status: RanToCompletion Inserted players into sample database leaderboard on instance cloudspanner-leaderboard
Użyjmy teraz biblioteki klienta w języku C#, aby wstawić w tabeli Scores 4 losowe wyniki wraz z sygnaturami czasowymi każdego gracza w tabeli Players.
Kolumna Timestamp w tabeli Scores jest zdefiniowana jako „sygnatura czasowa zatwierdzenia” za pomocą tej instrukcji SQL, która została wykonana podczas wcześniejszego uruchamiania polecenia create:
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
Zwróć uwagę na atrybut OPTIONS(allow_commit_timestamp=true). Powoduje to, że plik Timestamp jest „sygnaturą czasową zatwierdzenia” i umożliwia jego automatyczne wypełnianie dokładną sygnaturą czasową transakcji w przypadku operacji INSERT i UPDATE w danym wierszu tabeli.
W polu „sygnatura czasowa zatwierdzenia” możesz też wstawić własne wartości sygnatury czasowej tak długo, jak długo wstawisz sygnaturę czasową z wartością z przeszłości, co zrobimy na potrzeby tego ćwiczenia z programowania.
Teraz uruchom polecenie insert z tymi samymi wartościami argumentów, które użyliśmy przy wywołaniu polecenia create, dodając „wyniki”. jako dodatkowy „typ wstawiania”, . Pamiętaj, aby zastąpić PROJECT_ID identyfikatorem projektu utworzonym na początku tego ćwiczenia.
dotnet run insert PROJECT_ID cloudspanner-leaderboard leaderboard scores
Po kilku sekundach powinna pojawić się taka odpowiedź:
Waiting for insert players operation to complete... Done inserting player records... Operation status: RanToCompletion Inserted players into sample database leaderboard on instance cloudspanner-leaderboard
Uruchomiono insert z typem wstawiania określony jako scores wywołuje metodę InsertScoresAsync, która używa tych fragmentów kodu, aby wstawić losowo wygenerowaną sygnaturę czasową z datą i godziną przypadającą w przeszłości:
DateTime randomTimestamp = DateTime.Now
.AddYears(r.Next(-2, 1))
.AddMonths(r.Next(-12, 1))
.AddDays(r.Next(-28, 0))
.AddHours(r.Next(-24, 0))
.AddSeconds(r.Next(-60, 0))
.AddMilliseconds(r.Next(-100000, 0));
...
cmdInsert.Parameters["Timestamp"].Value = randomTimestamp.ToString("o");
Aby automatycznie wypełniać kolumnę Timestamp sygnaturą czasową, w której znajduje się pole „Wstaw” jako transakcja, możesz zamiast tego wstawić stałą C# SpannerParameter.CommitTimestamp, jak w tym fragmencie kodu:
cmd.Parameters["Timestamp"].Value = SpannerParameter.CommitTimestamp;
Po zakończeniu wczytywania danych sprawdźmy wartości, które właśnie zapisaliśmy w nowych tabelach. Najpierw wybierz bazę danych leaderboard, a potem tabelę Players. Kliknij kartę Data. Powinny być widoczne dane w kolumnach PlayerId i PlayerName tabeli.
Następnie sprawdźmy, czy tabela wyników zawiera też dane, klikając tabelę Scores i wybierając kartę Data. Powinny być widoczne dane w kolumnach PlayerId, Timestamp i Score tabeli.
Brawo! Zaktualizujmy nasz Program, aby uruchomić zapytania, na podstawie których możemy utworzyć tabelę wyników w grach.
6. Uruchamianie zapytań dotyczących tabel wyników
Po skonfigurowaniu bazy danych i wczytaniu informacji do tabel utwórzmy długi baner przy użyciu tych danych. W tym celu musimy odpowiedzieć na następujące 4 pytania:
- Którzy gracze są w „największej dziesiątce” wszech czasów?
- Którzy gracze są w „największej dziesiątce” roku?
- Którzy gracze są w „największej dziesiątce” dzień miesiąca?
- Którzy gracze są w „największej dziesiątce” dnia tygodnia?
Zaktualizujmy nasz Program, aby uruchamiać zapytania SQL, które pozwolą odpowiedzieć na te pytania.
Dodamy polecenie query, które umożliwi uruchamianie zapytań w celu uzyskania informacji wymaganych na potrzeby tablicy wyników.
Edytuj plik Program.cs w edytorze Cloud Shell, aby zaktualizować Program i dodać polecenie query.
Najpierw dodaj nowy blok poleceń query w interfejsie „Verbmap” w górnej części Programu, pod istniejącym blokiem poleceń insert:
[Verb("query", HelpText = "Query players with 'Top Ten' scores within a specific timespan "
+ "from sample Cloud Spanner database table.")]
class QueryOptions
{
[Value(0, HelpText = "The project ID of the project to use "
+ "when managing Cloud Spanner resources.", Required = true)]
public string projectId { get; set; }
[Value(1, HelpText = "The ID of the instance where the sample data resides.",
Required = true)]
public string instanceId { get; set; }
[Value(2, HelpText = "The ID of the database where the sample data resides.",
Required = true)]
public string databaseId { get; set; }
[Value(3, Default = 0, HelpText = "The timespan in hours that will be used to filter the "
+ "results based on a record's timestamp. The default will return the "
+ "'Top Ten' scores of all time.")]
public int timespan { get; set; }
}
Następnie dodaj metody Query i QueryAsync pod istniejącą metodą InsertScoresAsync:
public static object Query(string projectId,
string instanceId, string databaseId, int timespan)
{
var response = QueryAsync(
projectId, instanceId, databaseId, timespan);
response.Wait();
return ExitCode.Success;
}
public static async Task QueryAsync(
string projectId, string instanceId, string databaseId, int timespan)
{
string connectionString =
$"Data Source=projects/{projectId}/instances/"
+ $"{instanceId}/databases/{databaseId}";
// Create connection to Cloud Spanner.
using (var connection = new SpannerConnection(connectionString))
{
string sqlCommand;
if (timespan == 0)
{
// No timespan specified. Query Top Ten scores of all time.
sqlCommand =
@"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";
}
else
{
// Query Top Ten scores filtered by the timepan specified.
sqlCommand =
$@"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.ToString()} HOUR)
ORDER BY s.Score DESC LIMIT 10";
}
var cmd = connection.CreateSelectCommand(sqlCommand);
using (var reader = await cmd.ExecuteReaderAsync())
{
while (await reader.ReadAsync())
{
Console.WriteLine("PlayerId : "
+ reader.GetFieldValue<string>("PlayerId")
+ " PlayerName : "
+ reader.GetFieldValue<string>("PlayerName")
+ " Score : "
+ string.Format("{0:n0}",
Int64.Parse(reader.GetFieldValue<string>("Score")))
+ " Timestamp : "
+ reader.GetFieldValue<string>("Timestamp").Substring(0, 10));
}
}
}
}
Następnie, aby polecenie query działało, dodaj poniższy kod do sekcji „Main” (Główny) programu. :
.Add((QueryOptions opts) => Query(
opts.projectId, opts.instanceId, opts.databaseId, opts.timespan))
Aby zobaczyć przykładowy wygląd pliku Program.cs po dodaniu kodu włączającego polecenie query, możesz użyć pliku Program.cs z katalogu dotnet-docs-samples/applications/leaderboard/step6.
Teraz uruchom program, aby sprawdzić, czy nowe polecenie query znajduje się na liście możliwych poleceń programu. Uruchom to polecenie:
dotnet run
Polecenie query powinno pojawić się w domyślnych danych wyjściowych programu jako nowa opcja polecenia:
Leaderboard 1.0.0 Copyright (C) 2018 Leaderboard ERROR(S): No verb selected. create Create a sample Cloud Spanner database along with sample 'Players' and 'Scores' tables in your project. insert Insert sample 'players' records or 'scores' records into the database. query Query players with 'Top Ten' scores within a specific timespan from sample Cloud Spanner database table. help Display more information on a specific command. version Display version information.
Teraz uruchom polecenie query, aby zobaczyć argumenty wejściowe. Wpisz to polecenie:
dotnet run query
Zwróci to taką odpowiedź:
Leaderboard 1.0.0 Copyright (C) 2018 Leaderboard ERROR(S): A required value not bound to option name is missing. --help Display this help screen. --version Display version information. value pos. 0 Required. The project ID of the project to use when managing Cloud Spanner resources. value pos. 1 Required. The ID of the instance where the sample data resides. value pos. 2 Required. The ID of the database where the sample data resides. value pos. 3 (Default: 0) The timespan in hours that will be used to filter the results based on a record's timestamp. The default will return the 'Top Ten' scores of all time.
Z odpowiedzi wynika, że oprócz identyfikatora projektu, identyfikatora instancji oraz identyfikatora bazy danych jest oczekiwany jeszcze argument value pos. 3, który pozwala nam określić przedział czasu w liczbie godzin, który będzie używany do filtrowania rekordów na podstawie ich wartości w kolumnie Timestamp tabeli Scores. Ten argument ma wartość domyślną 0, co oznacza, że żadne rekordy nie będą filtrowane według sygnatur czasowych. Możemy więc użyć polecenia query bez atrybutu „okres” aby otrzymać listę 10 najlepszych graczy wszechczasów.
Uruchommy polecenie query bez określania zakresu czasu, używając tych samych wartości argumentów, które zostały użyte podczas uruchamiania polecenia create. Pamiętaj, aby zastąpić PROJECT_ID identyfikatorem projektu utworzonym na początku tego ćwiczenia.
dotnet run query PROJECT_ID cloudspanner-leaderboard leaderboard
Powinna pojawić się odpowiedź zawierająca pozycję „Dziesięć najlepszych” graczy wszech czasów jak poniżej:
PlayerId : 1843159180 PlayerName : Player 87 Score : 998,955 Timestamp : 2016-03-23
PlayerId : 61891198 PlayerName : Player 19 Score : 998,720 Timestamp : 2016-03-26
PlayerId : 340906298 PlayerName : Player 48 Score : 993,302 Timestamp : 2015-08-27
PlayerId : 541473117 PlayerName : Player 22 Score : 991,368 Timestamp : 2018-04-30
PlayerId : 857460496 PlayerName : Player 68 Score : 988,010 Timestamp : 2015-05-25
PlayerId : 1826646419 PlayerName : Player 91 Score : 984,022 Timestamp : 2016-11-26
PlayerId : 1002199735 PlayerName : Player 35 Score : 982,933 Timestamp : 2015-09-26
PlayerId : 2002563755 PlayerName : Player 23 Score : 979,041 Timestamp : 2016-10-25
PlayerId : 1377548191 PlayerName : Player 2 Score : 978,632 Timestamp : 2016-05-02
PlayerId : 1358098565 PlayerName : Player 65 Score : 973,257 Timestamp : 2016-10-30
Teraz uruchom polecenie query z niezbędnymi argumentami, aby wysłać zapytanie do listy „10 najwyższych wyników”. graczy w danym roku, określając przedział czasu równy liczbie godzin w roku, czyli 8760. Pamiętaj, aby zastąpić PROJECT_ID identyfikatorem projektu utworzonym na początku tego ćwiczenia.
dotnet run query PROJECT_ID cloudspanner-leaderboard leaderboard 8760
Powinna pojawić się odpowiedź zawierająca pozycję „Dziesięć najlepszych” graczy roku, na przykład:
PlayerId : 541473117 PlayerName : Player 22 Score : 991,368 Timestamp : 2018-04-30
PlayerId : 228469898 PlayerName : Player 82 Score : 967,177 Timestamp : 2018-01-26
PlayerId : 1131343000 PlayerName : Player 26 Score : 944,725 Timestamp : 2017-05-26
PlayerId : 396780730 PlayerName : Player 41 Score : 929,455 Timestamp : 2017-09-26
PlayerId : 61891198 PlayerName : Player 19 Score : 921,251 Timestamp : 2018-05-01
PlayerId : 634269851 PlayerName : Player 54 Score : 909,379 Timestamp : 2017-07-24
PlayerId : 821111159 PlayerName : Player 55 Score : 908,402 Timestamp : 2017-05-25
PlayerId : 228469898 PlayerName : Player 82 Score : 889,040 Timestamp : 2017-12-26
PlayerId : 1408782275 PlayerName : Player 27 Score : 874,124 Timestamp : 2017-09-24
PlayerId : 1002199735 PlayerName : Player 35 Score : 864,758 Timestamp : 2018-04-24
Teraz uruchommy polecenie query, aby wysłać zapytanie do listy „10 największych” graczy w miesiącu, określając „timespan” równa się liczbie godzin w miesiącu, która wynosi 730. Pamiętaj, aby zastąpić PROJECT_ID identyfikatorem projektu utworzonym na początku tego ćwiczenia.
dotnet run query PROJECT_ID cloudspanner-leaderboard leaderboard 730
Powinna pojawić się odpowiedź zawierająca pozycję „Dziesięć najlepszych” graczy w miesiącu na przykład tak:
PlayerId : 541473117 PlayerName : Player 22 Score : 991,368 Timestamp : 2018-04-30
PlayerId : 61891198 PlayerName : Player 19 Score : 921,251 Timestamp : 2018-05-01
PlayerId : 1002199735 PlayerName : Player 35 Score : 864,758 Timestamp : 2018-04-24
PlayerId : 1228490432 PlayerName : Player 11 Score : 682,033 Timestamp : 2018-04-26
PlayerId : 648239230 PlayerName : Player 92 Score : 653,895 Timestamp : 2018-05-02
PlayerId : 70762849 PlayerName : Player 77 Score : 598,074 Timestamp : 2018-04-22
PlayerId : 1671215342 PlayerName : Player 62 Score : 506,770 Timestamp : 2018-04-28
PlayerId : 1208850523 PlayerName : Player 21 Score : 216,008 Timestamp : 2018-04-30
PlayerId : 1587692674 PlayerName : Player 63 Score : 188,157 Timestamp : 2018-04-25
PlayerId : 992391797 PlayerName : Player 37 Score : 167,175 Timestamp : 2018-04-30
Teraz uruchommy polecenie query, aby wysłać zapytanie do listy „10 największych” graczy tygodnia poprzez określenie „czasu trwania”, co tydzień, czyli 168 godzin. Pamiętaj, aby zastąpić PROJECT_ID identyfikatorem projektu utworzonym na początku tego ćwiczenia.
dotnet run query PROJECT_ID cloudspanner-leaderboard leaderboard 168
Powinna pojawić się odpowiedź zawierająca pozycję „Dziesięć najlepszych” graczy tygodnia na przykład poniżej:
PlayerId : 541473117 PlayerName : Player 22 Score : 991,368 Timestamp : 2018-04-30
PlayerId : 61891198 PlayerName : Player 19 Score : 921,251 Timestamp : 2018-05-01
PlayerId : 228469898 PlayerName : Player 82 Score : 853,602 Timestamp : 2018-04-28
PlayerId : 1131343000 PlayerName : Player 26 Score : 695,318 Timestamp : 2018-04-30
PlayerId : 1228490432 PlayerName : Player 11 Score : 682,033 Timestamp : 2018-04-26
PlayerId : 1408782275 PlayerName : Player 27 Score : 671,827 Timestamp : 2018-04-27
PlayerId : 648239230 PlayerName : Player 92 Score : 653,895 Timestamp : 2018-05-02
PlayerId : 816861444 PlayerName : Player 83 Score : 622,277 Timestamp : 2018-04-27
PlayerId : 162043954 PlayerName : Player 75 Score : 572,634 Timestamp : 2018-05-02
PlayerId : 1671215342 PlayerName : Player 62 Score : 506,770 Timestamp : 2018-04-28
Doskonale!
Teraz podczas dodawania rekordów Spanner będzie skalować bazę danych odpowiednio do potrzebnego rozmiaru.
Bez względu na to, jak bardzo Twoja baza danych się rozrasta, tablica wyników Twojej gry może być nadal skalowalna z dokładnością dzięki usłudze Spanner i technologii Truetime.
7. Czyszczenie
Po całej zabawie ze Spannerem musimy też posprzątać nasz plac zabaw, by zaoszczędzić cenne zasoby i pieniądze. Na szczęście to łatwy krok. Wystarczy otworzyć konsolę programisty i usunąć instancję, którą utworzyliśmy w kroku z programowania o nazwie „Skonfiguruj instancję Cloud Spanner”.
8. Gratulacje!
Omówione zagadnienia:
- Schemat instancji, baz danych i tabel Google Cloud Spanner do tablicy wyników
- Jak utworzyć aplikację konsoli .NET Core C#
- Jak utworzyć bazę danych i tabele Spannera przy użyciu biblioteki klienta w języku C#
- Jak wczytać dane do bazy danych Spannera za pomocą biblioteki klienta w języku C#
- Jak wysłać zapytanie dotyczące listy „Top 10” wyników z Twoich danych za pomocą sygnatur czasowych zatwierdzenia usługi Spanner i biblioteki klienta w języku C#
Dalsze kroki:
- Przeczytaj dokument na temat platformy Sppanner CAP (w języku angielskim).
- Poznaj sprawdzone metody dotyczące projektowania schematu i zapytań
- Więcej informacji o sygnaturach czasowych zatwierdzenia w Cloud Spanner
Prześlij nam swoją opinię
- Poświęć chwilę na wypełnienie naszej bardzo krótkiej ankiety