쓰기 예시

이 문서에서는 Cloud Bigtable 클라이언트 라이브러리를 사용할 때 Bigtable에 보낼 수 있는 다양한 쓰기 요청 유형을 보여주는 코드 샘플을 제시합니다.

이 페이지의 예시에서는 SetCell 변형을 사용하여 비집계 셀에 쓰기 요청을 보냅니다. 집계 셀에 추가 요청을 보내는 방법의 예시는 쓰기 시 데이터 집계를 참조하세요.

쓰기 요청의 각 유형을 언제 사용하고 언제 사용하지 않아야 하는지에 대해 숙지한 후 이 샘플을 시도하세요.

Bigtable용 Python 클라이언트 라이브러리는 두 가지 API인 asyncio 및 동기 API를 제공합니다. 애플리케이션이 비동기인 경우 asyncio를 사용합니다.

이 페이지의 코드 샘플은 예시 데이터의 샘플 표를 참조합니다.

간단한 쓰기 수행

다음 코드 샘플은 Bigtable에 간단한 쓰기 요청을 수행하는 방법을 보여줍니다. 이러한 유형의 쓰기는 MutateRow API 요청입니다.

Go

Bigtable용 클라이언트 라이브러리를 설치하고 사용하는 방법은 Bigtable 클라이언트 라이브러리를 참조하세요.

Bigtable에 인증하려면 애플리케이션 기본 사용자 인증 정보를 설정합니다. 자세한 내용은 클라이언트 라이브러리의 인증 설정을 참조하세요. 

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)
	}