#google-cloud #spanner #gcp

google-cloud-spanner

Google Cloud Platform spanner client library

41 releases (breaking)

0.30.0 Jul 12, 2024
0.27.0 May 7, 2024
0.25.0 Dec 28, 2023
0.24.0 Oct 15, 2023
0.2.0 Nov 28, 2021

#2042 in Web programming

Download history 1236/week @ 2024-03-31 1104/week @ 2024-04-07 2727/week @ 2024-04-14 1550/week @ 2024-04-21 1302/week @ 2024-04-28 1557/week @ 2024-05-05 3539/week @ 2024-05-12 1589/week @ 2024-05-19 1071/week @ 2024-05-26 1862/week @ 2024-06-02 1268/week @ 2024-06-09 2126/week @ 2024-06-16 2698/week @ 2024-06-23 174/week @ 2024-06-30 313/week @ 2024-07-07 226/week @ 2024-07-14

3,446 downloads per month
Used in 2 crates

MIT license

8MB
144K SLoC

Bazel 112K SLoC // 0.1% comments Rust 32K SLoC // 0.0% comments Shell 181 SLoC // 0.3% comments Go 148 SLoC // 0.2% comments Forge Config 1 SLoC // 0.8% comments

google-cloud-spanner

Google Cloud Platform spanner library.

crates.io

Installation

[dependencies]
google-cloud-spanner = "version"

Quickstart

Create Client and call transaction API same as Google Cloud Go.

 use google_cloud_spanner::client::Client;
 use google_cloud_spanner::mutation::insert;
 use google_cloud_spanner::statement::Statement;
 use google_cloud_spanner::value::CommitTimestamp;
 use google_cloud_spanner::client::Error;

 #[tokio::main]
 async fn main() -> Result<(), Error> {

     const DATABASE: &str = "projects/local-project/instances/test-instance/databases/local-database";

     // Create spanner client
     let config = ClientConfig::default().with_auth().await.unwrap();
     let mut client = Client::new(DATABASE, config).await.unwrap();

     // Insert
     let mutation = insert("Guild", &["GuildId", "OwnerUserID", "UpdatedAt"], &[&"guildId", &"ownerId", &CommitTimestamp::new()]);
     let commit_timestamp = client.apply(vec![mutation]).await?;

     // Read with query
     let mut stmt = Statement::new("SELECT GuildId FROM Guild WHERE OwnerUserID = @OwnerUserID");
     stmt.add_param("OwnerUserID",&"ownerId");
     let mut tx = client.single().await?;
     let mut iter = tx.query(stmt).await?;
     while let Some(row) = iter.next().await? {
         let guild_id = row.column_by_name::<String>("GuildId");
     }

     // Remove all the sessions.
     client.close().await;
     Ok(())
 }

Performance

Result of the 24 hours Load Test.

Metrics This library Google Cloud Go
RPS 438.4 443.4
Used vCPU 0.37 ~ 0.42 0.65 ~ 0.70

Test condition

  • 2.0 vCPU GKE Autopilot Pod
  • 1 Node spanner database server
  • 100 Users
  • Here is the application for Load Test.

Dependencies

~16–31MB
~570K SLoC