Como usar o Cloud Spanner com Cloud Functions

Cloud Spanner

Objetivos

Escreva, implante e acione uma Cloud Function HTTP que acesse o Cloud Spanner.

Custos

Neste tópico, serão usados os componentes faturáveis Cloud Spanner e Cloud Functions do Google Cloud Platform.

Antes de começar

  1. Neste tópico, pressupomos que você tenha uma instância do Cloud Spanner denominada test-instance e um banco de dados denominado example-db que usa o esquema de aplicativo de música. Para instruções sobre como criar uma instância e um banco de dados com o esquema de aplicativo de música, consulte o Guia de início rápido do uso do console ou os tutoriais de primeiros passos em Go, Java, Node.js ou Python.
  1. Ative a API do Cloud Functions.
    Ativar a API Cloud Functions

  2. Instale e inicialize o Cloud SDK.

  3. Atualize e instale componentes do gcloud:

    Node.js 8/10

    gcloud components update

    Node.js 6 (descontinuado)

    gcloud components update

    Python

    gcloud components update

    Go

    gcloud components update

  4. Prepare seu ambiente de desenvolvimento:

Preparar o aplicativo

  1. Clone o repositório do app de amostra na máquina local:

    Node.js

    git clone https://github.com/GoogleCloudPlatform/nodejs-docs-samples.git

    Outra alternativa é fazer o download da amostra como um arquivo ZIP e extraí-lo.

    Python

    git clone https://github.com/GoogleCloudPlatform/python-docs-samples.git

    Outra alternativa é fazer o download da amostra como um arquivo ZIP e extraí-lo.

    Go

    git clone https://github.com/GoogleCloudPlatform/golang-samples.git

    Outra alternativa é fazer o download da amostra como um arquivo ZIP e extraí-lo.

  2. Passe para o diretório que contém o código de exemplo do Cloud Functions para acessar o Cloud Spanner:

    Node.js

    cd nodejs-docs-samples/functions/spanner/

    Python

    cd python-docs-samples/functions/spanner/

    Go

    cd golang-samples/functions/spanner/
  3. Confira o código de amostra:

    Node.js

    // Imports the Google Cloud client library
    const {Spanner} = require('@google-cloud/spanner');
    
    // Instantiates a client
    const spanner = new Spanner();
    
    // Your Cloud Spanner instance ID
    const instanceId = 'test-instance';
    
    // Your Cloud Spanner database ID
    const databaseId = 'example-db';
    
    /**
     * HTTP Cloud Function.
     *
     * @param {Object} req Cloud Function request context.
     * @param {Object} res Cloud Function response context.
     */
    exports.get = (req, res) => {
      // Gets a reference to a Cloud Spanner instance and database
      const instance = spanner.instance(instanceId);
      const database = instance.database(databaseId);
    
      // The query to execute
      const query = {
        sql: 'SELECT * FROM Albums',
      };
    
      // Execute the query
      return database
        .run(query)
        .then(results => {
          const rows = results[0].map(row => row.toJSON());
          rows.forEach(row => {
            res.write(
              `SingerId: ${row.SingerId}, AlbumId: ${row.AlbumId}, AlbumTitle: ${
                row.AlbumTitle
              }\n`
            );
          });
          res.status(200).end();
        })
        .catch(err => {
          res
            .status(500)
            .send(`Error querying Spanner: ${err}`)
            .end();
        });
    };

    Python

    from google.cloud import spanner
    
    instance_id = 'test-instance'
    database_id = 'example-db'
    
    client = spanner.Client()
    
    def spanner_read_data(request):
        instance = client.instance(instance_id)
        database = instance.database(database_id)
    
        query = 'SELECT * FROM Albums'
    
        outputs = []
        with database.snapshot() as snapshot:
            results = snapshot.execute_sql(query)
    
            for row in results:
                output = 'SingerId: {}, AlbumId: {}, AlbumTitle: {}'.format(*row)
                outputs.append(output)
    
        return '\n'.join(outputs)

    Go

    // Package spanner contains an example of using Spanner from a Cloud Function.
    package spanner
    
    import (
    	"context"
    	"fmt"
    	"log"
    	"net/http"
    
    	"cloud.google.com/go/spanner"
    	"google.golang.org/api/iterator"
    )
    
    // client is a global Spanner client, to avoid initializing a new client for
    // every request.
    var client *spanner.Client
    
    // db is the name of the database to query.
    var db = "projects/my-project/instances/my-instance/databases/example-db"
    
    // HelloSpanner is an example of querying Spanner from a Cloud Function.
    func HelloSpanner(w http.ResponseWriter, r *http.Request) {
    	if client == nil {
    		// Declare a separate err variable to avoid shadowing client.
    		var err error
    		client, err = spanner.NewClient(context.Background(), db)
    		if err != nil {
    			http.Error(w, "Error initializing database", http.StatusInternalServerError)
    			log.Printf("spanner.NewClient: %v", err)
    			return
    		}
    	}
    
    	fmt.Fprintln(w, "Albums:")
    	stmt := spanner.Statement{SQL: `SELECT SingerId, AlbumId, AlbumTitle FROM Albums`}
    	iter := client.Single().Query(r.Context(), stmt)
    	defer iter.Stop()
    	for {
    		row, err := iter.Next()
    		if err == iterator.Done {
    			return
    		}
    		if err != nil {
    			http.Error(w, "Error querying database", http.StatusInternalServerError)
    			log.Printf("iter.Next: %v", err)
    			return
    		}
    		var singerID, albumID int64
    		var albumTitle string
    		if err := row.Columns(&singerID, &albumID, &albumTitle); err != nil {
    			http.Error(w, "Error parsing database response", http.StatusInternalServerError)
    			log.Printf("row.Columns: %v", err)
    			return
    		}
    		fmt.Fprintf(w, "%d %d %s\n", singerID, albumID, albumTitle)
    	}
    }
    

    A função envia uma consulta SQL para buscar todos os dados de Albums do banco de dados. A função é executada quando você faz uma solicitação HTTP para o ponto de extremidade da função.

Implantar a função

Para implantar a função com um acionador HTTP, execute o seguinte comando no diretório spanner:

Node.js 8

gcloud functions deploy get --runtime nodejs8 --trigger-http

Node.js 10 (Beta)

gcloud functions deploy get --runtime nodejs10 --trigger-http

Node.js 6 (descontinuado)

gcloud functions deploy get --runtime nodejs6 --trigger-http

Python

gcloud functions deploy spanner_read_data --runtime python37 --trigger-http

Go

gcloud functions deploy HelloSpanner --runtime go111 --trigger-http

A implantação da função pode levar até 2 minutos.

Observe o valor de url retornado quando a implantação da função for concluída. Você o usará ao acionar a função.

Você pode ver as funções implantadas na página Cloud Functions no Console do Google Cloud Platform. Você também pode criar e editar funções nessa página e ver detalhes e diagnósticos das funções.

Acionar a função

Faça uma solicitação HTTP à função:

Node.js

curl "https://REGION-PROJECT_ID.cloudfunctions.net/get" 

Python

curl "https://REGION-PROJECT_ID.cloudfunctions.net/spanner_read_data" 

Go

curl "https://REGION-PROJECT_ID.cloudfunctions.net/HelloSpanner" 

em que REGION e PROJECT_ID correspondem aos valores visíveis no terminal quando a implantação da função for concluída. Será exibida a saída que mostra os resultados da consulta SQL, supondo que você seguiu um tutorial de primeiros passos e preencheu o banco de dados:

SingerId: 2, AlbumId: 2, AlbumTitle: Forever Hold Your Peace
SingerId: 1, AlbumId: 2, AlbumTitle: Go, Go, Go
SingerId: 2, AlbumId: 1, AlbumTitle: Green
SingerId: 2, AlbumId: 3, AlbumTitle: Terrified
SingerId: 1, AlbumId: 1, AlbumTitle: Total Junk

Você também pode visitar o URL da função no seu navegador para ver o resultado da sua consulta SQL.

Como fazer a limpeza

Para evitar cobranças adicionais na conta do GCP pelo uso dos recursos Cloud Spanner e Cloud Functions neste tópico:

  1. Exclua a instância:

    gcloud spanner instances delete test-instance
    
  2. Exclua a função que você implantou:

    Node.js

    gcloud functions delete get 

    Python

    gcloud functions delete spanner_read_data 

    Go

    gcloud functions delete HelloSpanner 

A seguir

Esta página foi útil? Conte sua opinião sobre:

Enviar comentários sobre…

Documentação do Cloud Spanner