Exemples d'écriture

Ce document présente des exemples de code illustrant les différents types de requêtes d'écriture que vous pouvez envoyer à Bigtable lorsque vous utilisez les bibliothèques clientes Cloud Bigtable.

Les exemples de cette page utilisent des mutations SetCell pour envoyer des requêtes d'écriture à des cellules non agrégées. Pour obtenir des exemples d'envoi de requêtes d'ajout afin d'agréger des cellules, consultez Agréger vos données au moment de l'écriture.

Avant de tester ces exemples, assurez-vous de bien comprendre quand utiliser et quand ne pas utiliser chaque type de requête d'écriture.

La bibliothèque cliente Python pour Bigtable propose deux API : asyncio et une API synchrone. Si votre application est asynchrone, utilisez asyncio.

Les exemples de code sur cette page font référence à l'exemple de tableau dans Données pour les exemples.

Effectuer une écriture simple

Les exemples de code suivants montrent comment effectuer des requêtes d'écriture simple dans Bigtable. Ce type d'écriture exécute une requête API MutateRow.

Go

Pour savoir comment installer et utiliser la bibliothèque cliente pour Bigtable, consultez la section Bibliothèques clientes Bigtable.

Pour vous authentifier auprès de Bigtable, configurez les Identifiants par défaut de l'application. Pour en savoir plus, consultez Configurer l'authentification pour les bibliothèques clientes. 

import (
	"context"
	"encoding/binary"
	"fmt"
	"io"

	"bytes"

	"cloud.google.com/go/bigtable"
)

func writeSimple(w io.Writer, projectID, instanceID string, tableName string) error {
	// projectID := "my-project-id"
	// instanceID := "my-instance-id"
	// tableName := "mobile-time-series"

	ctx := context.Background()
	client, err := bigtable.NewClient(ctx, projectID, instanceID)
	if err != nil {
		return fmt.Errorf("bigtable.NewClient: %w", err)
	}
	defer client.Close()
	tbl := client.Open(tableName)
	columnFamilyName := "stats_summary"
	timestamp := bigtable.Now()

	mut := bigtable.NewMutation()
	buf := new(bytes.Buffer)
	binary.Write(buf, binary.BigEndian, int64(1))

	mut.Set(columnFamilyName, "connected_cell", timestamp, buf.Bytes())
	mut.Set(columnFamilyName, "connected_wifi", timestamp, buf.Bytes())
	mut.Set(columnFamilyName, "os_build", timestamp, []byte("PQ2A.190405.003"))

	rowKey := "phone#4c410523#20190501"
	if err := tbl.Apply(ctx, rowKey, mut); err != nil {
		return fmt.Errorf("Apply: %w", err)
	}

	fmt.Fprintf(w, "Successfully wrote row: %s\n", rowKey)
	return nil
}

HBase

Pour savoir comment installer et utiliser la bibliothèque cliente pour Bigtable, consultez la section Bibliothèques clientes Bigtable.

Pour vous authentifier auprès de Bigtable, configurez les Identifiants par défaut de l'application. Pour en savoir plus, consultez Configurer l'authentification pour les bibliothèques clientes. 


import com.google.cloud.bigtable.hbase.BigtableConfiguration;
import