예시: C++ 'Hello World' 애플리케이션

이 예는 C#으로 작성된 간단한 'hello world' 애플리케이션으로, 다음을 수행하는 방법을 보여줍니다.

• Cloud Bigtable 인스턴스 연결
• 새 테이블 만들기
• 테이블에 데이터 쓰기
• 데이터 다시 읽기
• 테이블 삭제

샘플 실행

이 예시에서는 C++용 Google Cloud 클라이언트 라이브러리의 Cloud Bigtable 패키지를 사용하여 Cloud Bigtable과 통신합니다

이 샘플 프로그램을 실행하려면 GitHub에서 안내를 따르세요.

Google Cloud 클라이언트 라이브러리를 Bigtable과 함께 사용

샘플 애플리케이션을 Bigtable에 연결하여 몇 가지 간단한 작업을 보여줍니다.

클라이언트 라이브러리 설치 및 가져오기

GitHub에서 Cloud Bigtable C++ 클라이언트 라이브러리를 다운로드하거나 클론한 다음 컴파일합니다. 최상위 README의 컴파일러 안내를 따르세요.

필수 헤더를 포함합니다.

google/cloud/bigtable/examples/bigtable_hello_world.cc

GitHub에서 보기

#include "google/cloud/bigtable/admin/bigtable_table_admin_client.h"
#include "google/cloud/bigtable/resource_names.h"
#include "google/cloud/bigtable/table.h"

Bigtable에 연결

MakeBigtableTableAdminConnection()을 사용하여 테이블을 만드는 데 사용할 BigtableTableAdminClient를 구성합니다.

google/cloud/bigtable/examples/bigtable_hello_world.cc

GitHub에서 보기

cbta::BigtableTableAdminClient table_admin(
    cbta::MakeBigtableTableAdminConnection());

테이블 만들기

column family가 1개 있는 테이블의 스키마를 정의합니다. 각 값별로 최대 1개의 버전만 유지하도록 하는 가비지 컬렉션 규칙을 column family에 설정합니다. BigtableTableAdminClient::CreateTable()을 사용하여 테이블 객체를 인스턴스화합니다. 그런 다음 테이블에서 데이터를 가져오거나 내보내는 데 사용할 수 있는 데이터 클라이언트를 만듭니다.

google/cloud/bigtable/examples/bigtable_hello_world.cc

GitHub에서 보기

// Define the desired schema for the Table.
google::bigtable::admin::v2::GcRule gc;
gc.set_max_num_versions(1);
google::bigtable::admin::v2::Table t;
auto& families = *t.mutable_column_families();
*families["family"].mutable_gc_rule() = std::move(gc);

// Create a table.
std::string instance_name = cbt::InstanceName(project_id, instance_id);
StatusOr<google::bigtable::admin::v2::Table> schema =
    table_admin.CreateTable(instance_name, table_id, std::move(t));

// Create an object to access the Cloud Bigtable Data API.
cbt::Table table(cbt::MakeDataClient(project_id, instance_id), table_id);

테이블에 행 쓰기

인사말 문자열 목록을 반복하여 테이블의 새로운 행을 만듭니다. 각 반복 시 SingleRowMutation을 사용하여 행을 정의하고 row key와 값을 할당합니다. 그런 다음 Table::Apply()를 호출하여 행에 변형을 적용합니다.

google/cloud/bigtable/examples/bigtable_hello_world.cc

GitHub에서 보기

std::vector<std::string> greetings{"Hello World!", "Hello Cloud Bigtable!",
                                   "Hello C++!"};
int i = 0;
for (auto const& greeting : greetings) {
  // Each row has a unique row key.
  //
  // Note: This example uses sequential numeric IDs for simplicity, but
  // this can result in poor performance in a production application.
  // Since rows are stored in sorted order by key, sequential keys can
  // result in poor distribution of operations across nodes.
  //
  // For more information about how to design a Bigtable schema for the
  // best performance, see the documentation:
  //
  //     https://cloud.google.com/bigtable/docs/schema-design
  std::string row_key = "key-" + std::to_string(i);
  google::cloud::Status status = table.Apply(cbt::SingleRowMutation(
      std::move(row_key), cbt::SetCell("family", "c0", greeting)));

  if (!status.ok()) throw std::runtime_error(status.message());
  ++i;
}

필터 만들기

작성한 데이터를 읽기 전에 Bigtable이 반환하는 데이터를 제한하려면 Filter::ColumnRangeClosed()를 사용하여 필터를 생성합니다. 테이블에 만료되었지만 아직 가비지 컬렉션에 의해 삭제되지 않은 이전 셀이 있더라도 이 필터는 각 값의 최신 버전만 반환하도록 Bigtable에 지시합니다.

google/cloud/bigtable/examples/bigtable_hello_world.cc

GitHub에서 보기

cbt::Filter filter = cbt::Filter::ColumnRangeClosed("family", "c0", "c0");

키를 통해 행 읽기

Table::ReadRow() 함수를 호출하고 row key와 필터를 전달하여 행에서 각 값별로 버전 하나를 가져옵니다.

google/cloud/bigtable/examples/bigtable_hello_world.cc

GitHub에서 보기

StatusOr<std::pair<bool, cbt::Row>> result = table.ReadRow("key-0", filter);
if (!result) throw std::runtime_error(result.status().message());
if (!result->first) {
  std::cout << "Cannot find row 'key-0' in the table: " << table.table_name()
            << "\n";
  return;
}
cbt::Cell const& cell = result->second.cells().front();
std::cout << cell.family_name() << ":" << cell.column_qualifier() << "    @ "
          << cell.timestamp().count() << "us\n"
          << '"' << cell.value() << '"' << "\n";

모든 테이블 행 검색

Table::ReadRows()를 사용하여 테이블에서 행 범위를 읽습니다.

google/cloud/bigtable/examples/bigtable_hello_world.cc

GitHub에서 보기

for (StatusOr<cbt::Row> const& row : table.ReadRows(
         cbt::RowRange::InfiniteRange(), cbt::Filter::PassAllFilter())) {
  if (!row) throw std::runtime_error(row.status().message());
  std::cout << row->row_key() << ":\n";
  for (cbt::Cell const& c : row->cells()) {
    std::cout << "\t" << c.family_name() << ":" << c.column_qualifier()
              << "    @ " << c.timestamp().count() << "us\n"
              << "\t\"" << c.value() << '"' << "\n";
  }
}

테이블 삭제

BigtableTableAdminClient::DeleteTable()로 테이블을 삭제합니다.

google/cloud/bigtable/examples/bigtable_hello_world.cc

GitHub에서 보기

google::cloud::Status status = table_admin.DeleteTable(table.table_name());
if (!status.ok()) throw std::runtime_error(status.message());

하나로 결합

다음은 주석이 없는 전체 예시입니다.

google/cloud/bigtable/examples/bigtable_hello_world.cc

GitHub에서 보기

#include "google/cloud/bigtable/admin/bigtable_table_admin_client.h"
#include "google/cloud/bigtable/resource_names.h"
#include "google/cloud/bigtable/table.h"
#include "google/cloud/bigtable/examples/bigtable_examples_common.h"
#include "google/cloud/bigtable/testing/random_names.h"
#include "google/cloud/internal/getenv.h"
#include "google/cloud/internal/random.h"
#include "google/cloud/testing_util/crash_handler.h"
#include <iostream>

namespace {

using ::google::cloud::bigtable::examples::Usage;

void BigtableHelloWorld(std::vector<std::string> const& argv) {
  if (argv.size() != 3) {
    throw Usage{"hello-world <project-id> <instance-id> <table-id>"};
  }
  std::string const project_id = argv[0];
  std::string const instance_id = argv[1];
  std::string const table_id = argv[2];

  namespace cbt = ::google::cloud::bigtable;
  namespace cbta = ::google::cloud::bigtable_admin;
  using ::google::cloud::StatusOr;

  cbta::BigtableTableAdminClient table_admin(
      cbta::MakeBigtableTableAdminConnection());

  google::bigtable::admin::v2::GcRule gc;
  gc.set_max_num_versions(1);
  google::bigtable::admin::v2::Table t;
  auto& families = *t.mutable_column_families();
  *families["family"].mutable_gc_rule() = std::move(gc);

  std::string instance_name = cbt::InstanceName(project_id, instance_id);
  StatusOr<google::bigtable::admin::v2::Table> schema =
      table_admin.CreateTable(instance_name, table_id, std::move(t));

  cbt::Table table(cbt::MakeDataClient(project_id, instance_id), table_id);

  std::vector<std::string> greetings{"Hello World!", "Hello Cloud Bigtable!",
                                     "Hello C++!"};
  int i = 0;
  for (auto const& greeting : greetings) {
    std::string row_key = "key-" + std::to_string(i);
    google::cloud::Status status = table.Apply(cbt::SingleRowMutation(
        std::move(row_key), cbt::SetCell("family", "c0", greeting)));

    if (!status.ok()) throw std::runtime_error(status.message());
    ++i;
  }

  cbt::Filter filter = cbt::Filter::ColumnRangeClosed("family", "c0", "c0");

  StatusOr<std::pair<bool, cbt::Row>> result = table.ReadRow("key-0", filter);
  if (!result) throw std::runtime_error(result.status().message());
  if (!result->first) {
    std::cout << "Cannot find row 'key-0' in the table: " << table.table_name()
              << "\n";
    return;
  }
  cbt::Cell const& cell = result->second.cells().front();
  std::cout << cell.family_name() << ":" << cell.column_qualifier() << "    @ "
            << cell.timestamp().count() << "us\n"
            << '"' << cell.value() << '"' << "\n";

  for (StatusOr<cbt::Row> const& row : table.ReadRows(
           cbt::RowRange::InfiniteRange(), cbt::Filter::PassAllFilter())) {
    if (!row) throw std::runtime_error(row.status().message());
    std::cout << row->row_key() << ":\n";
    for (cbt::Cell const& c : row->cells()) {
      std::cout << "\t" << c.family_name() << ":" << c.column_qualifier()
                << "    @ " << c.timestamp().count() << "us\n"
                << "\t\"" << c.value() << '"' << "\n";
    }
  }

  google::cloud::Status status = table_admin.DeleteTable(table.table_name());
  if (!status.ok()) throw std::runtime_error(status.message());
}

void RunAll(std::vector<std::string> const& argv) {
  namespace examples = ::google::cloud::bigtable::examples;
  namespace cbt = ::google::cloud::bigtable;

  if (!argv.empty()) throw Usage{"auto"};
  if (!examples::RunAdminIntegrationTests()) return;
  examples::CheckEnvironmentVariablesAreSet({
      "GOOGLE_CLOUD_PROJECT",
      "GOOGLE_CLOUD_CPP_BIGTABLE_TEST_INSTANCE_ID",
  });
  auto const project_id =
      google::cloud::internal::GetEnv("GOOGLE_CLOUD_PROJECT").value();
  auto const instance_id = google::cloud::internal::GetEnv(
                               "GOOGLE_CLOUD_CPP_BIGTABLE_TEST_INSTANCE_ID")
                               .value();

  auto generator = google::cloud::internal::DefaultPRNG(std::random_device{}());
  auto table_id = cbt::testing::RandomTableId(generator);

  std::cout << "\nRunning the BigtableHelloWorld() example" << std::endl;
  BigtableHelloWorld({project_id, instance_id, table_id});
}

}  // namespace

int main(int argc, char* argv[]) {
  google::cloud::testing_util::InstallCrashHandler(argv[0]);

  google::cloud::bigtable::examples::Example example({
      {"auto", RunAll},
      {"hello-world", BigtableHelloWorld},
  });
  return example.Run(argc, argv);
}