자습서: Azure Cosmos DB에서 Cassandra용 API 테이블에 샘플 데이터 로드

2025-07-08

적용 대상: 카산드라

개발자는 키/값 쌍을 사용하는 애플리케이션을 가질 수도 있습니다. Azure Cosmos DB의 Cassandra 계정에 대한 API를 사용하여 키/값 데이터를 저장하고 관리할 수 있습니다. 이 자습서에서는 Java 애플리케이션을 사용하여 Azure Cosmos DB의 Cassandra 계정에 대한 API의 테이블에 샘플 사용자 데이터를 로드하는 방법을 보여 줍니다. Java 애플리케이션은 Java 드라이버를 사용하고 사용자 ID, 사용자 이름 및 사용자 도시와 같은 사용자 데이터를 로드합니다.

이 자습서에서 다루는 작업은 다음과 같습니다.

Cassandra 테이블에 데이터를 로드합니다.
앱을 실행하세요.

필수 조건

Azure 구독이 없는 경우, 시작하기 전에 무료 계정을 만드십시오.
이 문서는 다중 파트 자습서에 속합니다. 이 문서를 시작하기 전에 Cassandra 계정, 키스페이스 및 테이블에 대한 API를 만들어야 합니다.

테이블에 데이터 로드

Cassandra용 API 테이블에 데이터를 로드하려면 다음 단계를 수행합니다.

UserRepository.java 폴더 아래에서 src\main\java\com\azure\cosmosdb\cassandra 파일을 엽니다. 테이블에 user_id, user_name, user_bcity 필드를 삽입하는 코드를 추가합니다.

/**
* Insert a row into user table
*
* @param id   user_id
* @param name user_name
* @param city user_bcity
*/
public void insertUser(PreparedStatement statement, int id, String name, String city) {
     BoundStatement boundStatement = new BoundStatement(statement);
     session.execute(boundStatement.bind(id, name, city));
}

/**
* Create a PrepareStatement to insert a row to user table
*
* @return PreparedStatement
*/
public PreparedStatement prepareInsertStatement() {
   final String insertStatement = "INSERT INTO  uprofile.user (user_id, user_name , user_bcity) VALUES (?,?,?)";
return session.prepare(insertStatement);
}

UserProfile.java 폴더 아래에서 src\main\java\com\azure\cosmosdb\cassandra 파일을 엽니다. 이 클래스는 앞에서 정의한 createKeyspace 및 createTable 메서드를 호출하는 메인 메서드를 포함합니다. 이제 다음 코드를 추가하여 일부 샘플 데이터를 API for Cassandra 테이블에 삽입합니다.

//Insert rows into user table
PreparedStatement preparedStatement = repository.prepareInsertStatement();
  repository.insertUser(preparedStatement, 1, "JohnH", "Seattle");
  repository.insertUser(preparedStatement, 2, "EricK", "Spokane");
  repository.insertUser(preparedStatement, 3, "MatthewP", "Tacoma");
  repository.insertUser(preparedStatement, 4, "DavidA", "Renton");
  repository.insertUser(preparedStatement, 5, "PeterS", "Everett");

앱 실행

명령 프롬프트 또는 터미널 창을 열고 프로젝트를 만든 위치로 폴더 경로를 변경합니다. mvn clean install 명령을 실행하여 대상 폴더 내에서 파일을 생성 cosmosdb-cassandra-examples.jar 하고 애플리케이션을 실행합니다.

cd "cassandra-demo"

mvn clean install

java -cp target/cosmosdb-cassandra-examples.jar com.azure.cosmosdb.cassandra.examples.UserProfile

이제 Azure Portal에서 데이터 탐색기를 열어 사용자 정보가 테이블에 추가되었는지 확인할 수 있습니다.

다음 단계

이 자습서에서는 Azure Cosmos DB에서 Cassandra용 API 계정에 샘플 데이터를 로드하는 방법을 알아보았습니다. 이제 다음 문서로 진행할 수 있습니다.

API for Cassandra 계정에서 데이터 쿼리