빠른 시작: Java SDK 및 Azure Cosmos DB를 사용하여 API for Table 앱 빌드
적용 대상: 
테이블
이 빠른 시작에서는 Java 애플리케이션에서 Azure Cosmos DB Tables API에 액세스하는 방법을 보여줍니다. Azure Cosmos DB Tables API는 애플리케이션이 구조화된 NoSQL 데이터를 클라우드에 저장할 수 있도록 하는 스키마 없는 데이터 저장소입니다. 데이터가 스키마 없는 디자인에 저장되므로, 새 특성이 있는 개체가 테이블에 추가되면 테이블에 새 속성(열)이 자동으로 추가됩니다.
Java 애플리케이션은 azure-data-tables 클라이언트 라이브러리를 사용하여 Azure Cosmos DB Tables API에 액세스할 수 있습니다.
필수 조건
샘플 애플리케이션은 Spring Boot 2.6.4로 작성되었습니다. Visual Studio Code 또는 IntelliJ IDEA를 IDE로 사용할 수 있습니다.
Azure 구독이 아직 없는 경우 시작하기 전에 체험 계정을 만듭니다.
샘플 응용 프로그램
이 자습서의 샘플 애플리케이션은 리포지토리 https://github.com/Azure-Samples/msdocs-azure-data-tables-sdk-java에서 복제하거나 다운로드할 수 있습니다. 시작 및 완료된 앱은 모두 샘플 리포지토리에 포함됩니다.
git clone https://github.com/Azure-Samples/msdocs-azure-data-tables-sdk-java
샘플 애플리케이션은 날씨 데이터를 예제로 사용하여 Table API의 기능을 보여줍니다. 날씨 관측을 나타내는 개체는 API for Table을 사용하여 저장 및 검색됩니다. 여기에는 Tables API의 스키마 없는 기능을 보여주기 위해 추가 속성이 있는 개체 저장이 포함됩니다.
1 - Azure Cosmos DB 계정 만들기
먼저 애플리케이션에서 사용되는 테이블을 포함할 Azure Cosmos DB Tables API 계정을 만들어야 합니다. 이 작업은 Azure Portal, Azure CLI 또는 Azure PowerShell을 사용하여 수행할 수 있습니다.
Azure Portal에 로그인하고 다음 단계에 따라 Azure Cosmos DB 계정을 만듭니다.
| 지침 | 스크린샷 |
|---|---|
Azure Portal에서 다음을 수행합니다.
|
|
| Azure Cosmos DB 페이지에서 +만들기를 선택합니다. | 
|
| API 옵션 선택 페이지에서 Azure Table 옵션을 선택합니다. | 
|
Azure Cosmos DB 계정 만들기 - Azure Table 페이지에서 다음과 같이 양식을 작성합니다.
|
|
2 - 테이블 만들기
다음으로 애플리케이션에서 사용할 Azure Cosmos DB 계정 내에 테이블을 만들어야 합니다. 기존 데이터베이스와 달리, 테이블의 속성(열)이 아니라 테이블의 이름만 지정하면 됩니다. 데이터가 테이블에 로드되면 필요에 따라 속성(열)이 자동으로 만들어집니다.
Azure Portal에서 다음 단계를 완료하여 Azure Cosmos DB 계정 내에 테이블을 만듭니다.
| 지침 | 스크린샷 |
|---|---|
| Azure Portal에서 Azure Cosmos DB 계정의 개요 페이지로 이동합니다. 위쪽 검색 창에 Azure Cosmos DB 계정의 이름(cosmos-msdocs-tables-sdk-demo-XYZ)을 입력하고 리소스 제목 아래를 보면 Azure Cosmos DB 계정의 개요 페이지로 이동할 수 있습니다. Azure Cosmos DB 계정의 이름을 선택하여 개요 페이지로 이동합니다. | 
|
| 개요 페이지에서 +테이블 추가를 선택합니다. 새 테이블 대화 상자가 페이지의 오른쪽에서 서서히 표시됩니다. | 
|
새 테이블 대화 상자에서 다음과 같이 양식을 작성합니다.
|
|
3 - Azure Cosmos DB 연결 문자열 가져오기
Azure Cosmos DB의 테이블에 액세스하려면 앱에 CosmosDB Storage 계정에 대한 테이블 연결 문자열이 필요합니다. 이 연결 문자열은 Azure Portal, Azure CLI 또는 Azure PowerShell을 사용하여 검색할 수 있습니다.
| 지침 | 스크린샷 |
|---|---|
| Azure Cosmos DB 계정 페이지의 왼쪽에서 설정 머리글 아래에서 연결 문자열이라는 메뉴 항목을 찾아 선택합니다. 스토리지 계정에 대한 연결 문자열을 검색할 수 있는 페이지로 이동됩니다. | 
|
| 애플리케이션에서 사용할 기본 연결 문자열 값을 복사합니다. | 
|
Azure Cosmos DB 계정에 대한 연결 문자열은 앱 비밀로 간주되며 다른 앱 비밀 또는 암호처럼 보호해야 합니다. 이 예제에서는 POM을 사용하여 개발 중에 연결 문자열을 저장하고 애플리케이션에 제공합니다.
<profiles>
<profile>
<id>local</id>
<properties>
<azure.tables.connection.string>
<![CDATA[YOUR-DATA-TABLES-SERVICE-CONNECTION-STRING]]>
</azure.tables.connection.string>
<azure.tables.tableName>WeatherData</azure.tables.tableName>
</properties>
<activation>
<activeByDefault>true</activeByDefault>
</activation>
</profile>
</profiles>
4 - azure-data-tables 패키지 포함
Java 애플리케이션에서 Azure Cosmos DB Tables API에 액세스하려면 azure-data-tables 패키지를 포함합니다.
<dependency>
<groupId>com.azure</groupId>
<artifactId>azure-data-tables</artifactId>
<version>12.2.1</version>
</dependency>
5 - TableServiceConfig.java에서 테이블 클라이언트 구성
Azure SDK는 클라이언트 개체를 통해 Azure와 통신하여 Azure에 대해 다양한 작업을 실행합니다. TableClient 개체는 Azure Cosmos DB Tables API와 통신하는 데 사용되는 개체입니다.
애플리케이션은 일반적으로 애플리케이션 전체에서 사용할 TableClient 개체를 테이블마다 하나씩 만듭니다. 메서드가 Spring 컨테이너에서 관리할 TableClient 개체 bean을 생성하고 이를 수행하기 위한 싱글톤으로 생성하는 것으로 나타내는 것이 좋습니다.
애플리케이션의 TableServiceConfig.java 파일에서 다음 코드 조각과 일치하도록 tableClientConfiguration() 메서드를 편집합니다.
@Configuration
public class TableServiceConfiguration {
private static String TABLE_NAME;
private static String CONNECTION_STRING;
@Value("${azure.tables.connection.string}")
public void setConnectionStringStatic(String connectionString) {
TableServiceConfiguration.CONNECTION_STRING = connectionString;
}
@Value("${azure.tables.tableName}")
public void setTableNameStatic(String tableName) {
TableServiceConfiguration.TABLE_NAME = tableName;
}
@Bean
public TableClient tableClientConfiguration() {
return new TableClientBuilder()
.connectionString(CONNECTION_STRING)
.tableName(TABLE_NAME)
.buildClient();
}
}
또한 TableServiceConfig.java 파일의 맨 위에 있는 명령문을 사용하여 다음을 추가해야 합니다.
import com.azure.data.tables.TableClient;
import com.azure.data.tables.TableClientBuilder;
6 - Azure Cosmos DB 테이블 작업 구현
샘플 앱에 대한 모든 Azure Cosmos DB 테이블 작업은 Services 디렉터리에 있는 TablesServiceImpl 클래스에서 구현됩니다. com.azure.data.tables SDK 패키지를 가져와야 합니다.
import com.azure.data.tables.TableClient;
import com.azure.data.tables.models.ListEntitiesOptions;
import com.azure.data.tables.models.TableEntity;
import com.azure.data.tables.models.TableTransactionAction;
import com.azure.data.tables.models.TableTransactionActionType;
TableClient 개체를 이 클래스에 삽입할 수 있도록 TableServiceImpl 클래스의 시작 부분에 TableClient 개체의 멤버 변수와 생성자를 추가합니다.
@Autowired
private TableClient tableClient;
테이블에서 행 가져오기
TableClient 클래스에는 테이블에서 행을 선택할 수 있는 listEntities라는 메서드가 포함되어 있습니다. 이 예제에서는 이 메서드에 전달되는 매개 변수가 없으므로 테이블의 모든 행이 선택됩니다.
또한 이 메서드는 모델 클래스 데이터가 반환될 형식을 지정하는 TableEntity 형식의 제네릭 매개 변수를 사용합니다. 이 경우 기본 제공 클래스 TableEntity가 사용됩니다. 즉, listEntities 메서드는 PagedIterable<TableEntity> 컬렉션을 결과로 반환합니다.
public List<WeatherDataModel> retrieveAllEntities() {
List<WeatherDataModel> modelList = tableClient.listEntities().stream()
.map(WeatherDataUtils::mapTableEntityToWeatherDataModel)
.collect(Collectors.toList());
return Collections.unmodifiableList(WeatherDataUtils.filledValue(modelList));
}
com.azure.data.tables.models 패키지에 정의된 TableEntity 클래스에는 테이블의 파티션 키 및 행 키 값에 대한 속성이 있습니다. 이러한 두 값을 테이블에 있는 행의 고유 키 값으로 사용할 수 있습니다. 이 예제 애플리케이션에서는 기상 관측소(도시)의 이름이 파티션 키에 저장되고 관측 날짜/시간이 행 키에 저장됩니다. 그 외의 모든 속성(온도, 습도, 풍속)은 TableEntity 개체의 사전에 저장됩니다.
TableEntity 개체를 자체 정의의 개체에 매핑하는 것이 일반적입니다. 샘플 애플리케이션은 이러한 목적을 위해 Models 디렉터리에 WeatherDataModel 클래스를 정의합니다. 이 클래스는 파티션 키와 행 키가 매핑되는 관측소 이름 및 관측 날짜에 대한 속성을 갖고 있으며, 이러한 값에 대한 보다 의미 있는 속성 이름을 제공합니다. 그런 다음, 사전을 사용하여 개체의 나머지 속성을 저장합니다. 행에 임의의 속성이 여러 개 있을 수 있고 모델 개체가 모든 속성을 캡처할 수 있기를 원하기 때문에 테이블 스토리지를 사용할 때 일반적인 패턴입니다. 이 클래스에는 클래스의 속성을 나열하는 메서드도 포함되어 있습니다.
public class WeatherDataModel {
public WeatherDataModel(String stationName, String observationDate, OffsetDateTime timestamp, String etag) {
this.stationName = stationName;
this.observationDate = observationDate;
this.timestamp = timestamp;
this.etag = etag;
}
private String stationName;
private String observationDate;
private OffsetDateTime timestamp;
private String etag;
private Map<String, Object> propertyMap = new HashMap<String, Object>();
public String getStationName() {
return stationName;
}
public void setStationName(String stationName) {
this.stationName = stationName;
}
public String getObservationDate() {
return observationDate;
}
public void setObservationDate(String observationDate) {
this.observationDate = observationDate;
}
public OffsetDateTime getTimestamp() {
return timestamp;
}
public void setTimestamp(OffsetDateTime timestamp) {
this.timestamp = timestamp;
}
public String getEtag() {
return etag;
}
public void setEtag(String etag) {
this.etag = etag;
}
public Map<String, Object> getPropertyMap() {
return propertyMap;
}
public void setPropertyMap(Map<String, Object> propertyMap) {
this.propertyMap = propertyMap;
}
}
mapTableEntityToWeatherDataModel 메서드는 TableEntity 개체를 WeatherDataModel 개체에 매핑하는 데 사용됩니다. mapTableEntityToWeatherDataModel 메서드는 PartitionKey, RowKey, Timestamp 및 Etag 속성을 직접 매핑한 다음, properties.keySet를 사용하여 TableEntity 개체의 다른 속성을 반복하고 이미 직접 매핑된 속성을 제외한 나머지 속성을 WeatherDataModel 개체에 매핑합니다.
다음 코드 블록과 일치하도록 mapTableEntityToWeatherDataModel 메서드의 코드를 편집합니다.
public static WeatherDataModel mapTableEntityToWeatherDataModel(TableEntity entity) {
WeatherDataModel observation = new WeatherDataModel(
entity.getPartitionKey(), entity.getRowKey(),
entity.getTimestamp(), entity.getETag());
rearrangeEntityProperties(observation.getPropertyMap(), entity.getProperties());
return observation;
}
private static void rearrangeEntityProperties(Map<String, Object> target, Map<String, Object> source) {
Constants.DEFAULT_LIST_OF_KEYS.forEach(key -> {
if (source.containsKey(key)) {
target.put(key, source.get(key));
}
});
source.keySet().forEach(key -> {
if (Constants.DEFAULT_LIST_OF_KEYS.parallelStream().noneMatch(defaultKey -> defaultKey.equals(key))
&& Constants.EXCLUDE_TABLE_ENTITY_KEYS.parallelStream().noneMatch(defaultKey -> defaultKey.equals(key))) {
target.put(key, source.get(key));
}
});
}
테이블에서 반환된 행 필터링
테이블에서 반환된 행을 필터링하려면 OData 스타일 필터 문자열을 listEntities 메서드에 전달하면 됩니다. 예를 들어 2021년 7월 1일 자정부터 2021년 7월 2일 자정(포함) 사이의 모든 시카고 날씨 판독값을 가져오려면 다음 필터 문자열을 전달합니다.
PartitionKey eq 'Chicago' and RowKey ge '2021-07-01 12:00 AM' and RowKey le '2021-07-02 12:00 AM'
OData 웹 사이트의 필터 시스템 쿼리 옵션 섹션에서 모든 OData 필터 연산자를 확인할 수 있습니다.
예제 애플리케이션에서 FilterResultsInputModel 개체는 사용자가 제공한 필터 조건을 캡처하도록 설계되었습니다.
public class FilterResultsInputModel implements Serializable {
private String partitionKey;
private String rowKeyDateStart;
private String rowKeyTimeStart;
private String rowKeyDateEnd;
private String rowKeyTimeEnd;
private Double minTemperature;
private Double maxTemperature;
private Double minPrecipitation;
private Double maxPrecipitation;
public String getPartitionKey() {
return partitionKey;
}
public void setPartitionKey(String partitionKey) {
this.partitionKey = partitionKey;
}
public String getRowKeyDateStart() {
return rowKeyDateStart;
}
public void setRowKeyDateStart(String rowKeyDateStart) {
this.rowKeyDateStart = rowKeyDateStart;
}
public String getRowKeyTimeStart() {
return rowKeyTimeStart;
}
public void setRowKeyTimeStart(String rowKeyTimeStart) {
this.rowKeyTimeStart = rowKeyTimeStart;
}
public String getRowKeyDateEnd() {
return rowKeyDateEnd;
}
public void setRowKeyDateEnd(String rowKeyDateEnd) {
this.rowKeyDateEnd = rowKeyDateEnd;
}
public String getRowKeyTimeEnd() {
return rowKeyTimeEnd;
}
public void setRowKeyTimeEnd(String rowKeyTimeEnd) {
this.rowKeyTimeEnd = rowKeyTimeEnd;
}
public Double getMinTemperature() {
return minTemperature;
}
public void setMinTemperature(Double minTemperature) {
this.minTemperature = minTemperature;
}
public Double getMaxTemperature() {
return maxTemperature;
}
public void setMaxTemperature(Double maxTemperature) {
this.maxTemperature = maxTemperature;
}
public Double getMinPrecipitation() {
return minPrecipitation;
}
public void setMinPrecipitation(Double minPrecipitation) {
this.minPrecipitation = minPrecipitation;
}
public Double getMaxPrecipitation() {
return maxPrecipitation;
}
public void setMaxPrecipitation(Double maxPrecipitation) {
this.maxPrecipitation = maxPrecipitation;
}
}
이 개체는 TableServiceImpl 클래스의 retrieveEntitiesByFilter 메서드에 전달되면 null이 아닌 각 속성 값에 대한 필터 문자열을 만듭니다. 그런 다음, 모든 값을 "and" 절과 조인하여 결합된 필터 문자열을 만듭니다. 이 결합된 필터 문자열은 TableClient 개체의 listEntities 메서드에 전달되며 필터 문자열과 일치하는 행만 반환됩니다. 비슷한 메서드를 코드에 사용하여 애플리케이션에 필요한 적절한 필터 문자열을 생성할 수 있습니다.
public List<WeatherDataModel> retrieveEntitiesByFilter(FilterResultsInputModel model) {
List<String> filters = new ArrayList<>();
if (!StringUtils.isEmptyOrWhitespace(model.getPartitionKey())) {
filters.add(String.format("PartitionKey eq '%s'", model.getPartitionKey()));
}
if (!StringUtils.isEmptyOrWhitespace(model.getRowKeyDateStart())
&& !StringUtils.isEmptyOrWhitespace(model.getRowKeyTimeStart())) {
filters.add(String.format("RowKey ge '%s %s'", model.getRowKeyDateStart(), model.getRowKeyTimeStart()));
}
if (!StringUtils.isEmptyOrWhitespace(model.getRowKeyDateEnd())
&& !StringUtils.isEmptyOrWhitespace(model.getRowKeyTimeEnd())) {
filters.add(String.format("RowKey le '%s %s'", model.getRowKeyDateEnd(), model.getRowKeyTimeEnd()));
}
if (model.getMinTemperature() != null) {
filters.add(String.format("Temperature ge %f", model.getMinTemperature()));
}
if (model.getMaxTemperature() != null) {
filters.add(String.format("Temperature le %f", model.getMaxTemperature()));
}
if (model.getMinPrecipitation() != null) {
filters.add(String.format("Precipitation ge %f", model.getMinPrecipitation()));
}
if (model.getMaxPrecipitation() != null) {
filters.add(String.format("Precipitation le %f", model.getMaxPrecipitation()));
}
List<WeatherDataModel> modelList = tableClient.listEntities(new ListEntitiesOptions()
.setFilter(String.join(" and ", filters)), null, null).stream()
.map(WeatherDataUtils::mapTableEntityToWeatherDataModel)
.collect(Collectors.toList());
return Collections.unmodifiableList(WeatherDataUtils.filledValue(modelList));
}
TableEntity 개체를 사용하여 데이터 삽입
테이블에 데이터를 추가하는 가장 간단한 방법은 TableEntity 개체를 사용하는 것입니다. 이 예제에서는 데이터가 입력 모델 개체에서 TableEntity 개체로 매핑됩니다. 기상 관측소 이름과 관측 날짜/시간을 나타내는 입력 개체의 속성은 각각 PartitionKey 및 RowKey 속성에 매핑되어 테이블의 행에 대한 고유 키를 형성합니다. 그런 다음, 입력 모델 개체의 추가 속성이 TableClient 개체의 사전 속성에 매핑됩니다. 마지막으로, TableClient 개체의 createEntity 메서드를 사용하여 테이블에 데이터를 삽입합니다.
다음 코드를 포함하도록 예제 애플리케이션에서 insertEntity 클래스를 수정합니다.
public void insertEntity(WeatherInputModel model) {
tableClient.createEntity(WeatherDataUtils.createTableEntity(model));
}
TableEntity 개체를 사용하여 데이터 upsert
해당 테이블에 이미 있는 파티션 키/행 키 조합으로 테이블에 행을 삽입하려고 하면 오류가 발생합니다. 이러한 이유로 테이블에 행을 추가할 때 insertEntity 메서드 대신 upsertEntity를 사용하는 것이 좋습니다. 지정된 파티션 키/행 키 조합이 테이블에 이미 있는 경우 upsertEntity 메서드는 기존 행을 업데이트합니다. 그렇지 않으면 행이 테이블에 추가됩니다.
public void upsertEntity(WeatherInputModel model) {
tableClient.upsertEntity(WeatherDataUtils.createTableEntity(model));
}
변수 속성이 있는 데이터 삽입 또는 upsert
Azure Cosmos DB Tables API를 사용할 때의 이점 중 하나는 테이블에 로드되는 개체에 새 속성이 포함된 경우 해당 속성이 테이블에 자동으로 추가되고 값이 Azure Cosmos DB에 저장된다는 것입니다. 기존 데이터베이스에서 하는 것처럼 열을 추가하기 위해 ALTER TABLE과 같은 DDL 문을 실행할 필요가 없습니다.
이 모델은 시간에 따라 캡처해야 하는 데이터를 추가하거나 수정할 수 있는 데이터 원본을 처리할 때 또는 다른 입력에서 애플리케이션에 다른 데이터를 제공할 때 애플리케이션에 유연성을 제공합니다. 샘플 애플리케이션에서는 기본 날씨 데이터뿐 아니라 몇 가지 추가 값도 전송하는 기상 관측소를 시뮬레이션할 수 있습니다. 이러한 새 속성을 가진 개체가 처음으로 테이블에 저장되면 해당 속성(열)이 테이블에 자동으로 추가됩니다.
샘플 애플리케이션에서 ExpandableWeatherObject 클래스는 개체의 속성 세트를 지원하기 위해 내부 사전을 중심으로 빌드됩니다. 이 클래스는 개체가 임의의 속성 세트를 포함해야 하는 경우의 일반적인 패턴을 나타냅니다.
public class ExpandableWeatherObject {
private String stationName;
private String observationDate;
private Map<String, Object> propertyMap = new HashMap<String, Object>();
public String getStationName() {
return stationName;
}
public void setStationName(String stationName) {
this.stationName = stationName;
}
public String getObservationDate() {
return observationDate;
}
public void setObservationDate(String observationDate) {
this.observationDate = observationDate;
}
public Map<String, Object> getPropertyMap() {
return propertyMap;
}
public void setPropertyMap(Map<String, Object> propertyMap) {
this.propertyMap = propertyMap;
}
public boolean containsProperty(String key) {
return this.propertyMap.containsKey(key);
}
public Object getPropertyValue(String key) {
return containsProperty(key) ? this.propertyMap.get(key) : null;
}
public void putProperty(String key, Object value) {
this.propertyMap.put(key, value);
}
public List<String> getPropertyKeys() {
List<String> list = Collections.synchronizedList(new ArrayList<String>());
Iterator<String> iterators = this.propertyMap.keySet().iterator();
while (iterators.hasNext()) {
list.add(iterators.next());
}
return Collections.unmodifiableList(list);
}
public Integer getPropertyCount() {
return this.propertyMap.size();
}
}
API for Table을 사용하여 이러한 개체를 삽입하거나 upsert하려면 확장 가능한 개체의 속성을 TableEntity 개체에 매핑하고 TableClient 개체에서 createEntity 또는 upsertEntity 메서드를 적절하게 사용합니다.
public void insertExpandableEntity(ExpandableWeatherObject model) {
tableClient.createEntity(WeatherDataUtils.createTableEntity(model));
}
public void upsertExpandableEntity(ExpandableWeatherObject model) {
tableClient.upsertEntity(WeatherDataUtils.createTableEntity(model));
}
엔터티 업데이트
TableClient 개체에서 updateEntity 메서드를 호출하여 엔터티를 업데이트할 수 있습니다. Table API를 사용하여 저장된 엔터티(행)에는 임의의 속성 세트가 포함될 수 있으므로, 앞에서 설명한 ExpandableWeatherObject와 유사한 사전 개체를 중심으로 업데이트 개체를 만드는 것이 좋은 경우가 자주 있습니다. 이 경우 유일한 차이점은 업데이트 중에 동시성 제어에 사용되는 etag 속성이 추가된다는 것입니다.
public class UpdateWeatherObject {
private String stationName;
private String observationDate;
private String etag;
private Map<String, Object> propertyMap = new HashMap<String, Object>();
public String getStationName() {
return stationName;
}
public void setStationName(String stationName) {
this.stationName = stationName;
}
public String getObservationDate() {
return observationDate;
}
public void setObservationDate(String observationDate) {
this.observationDate = observationDate;
}
public String getEtag() {
return etag;
}
public void setEtag(String etag) {
this.etag = etag;
}
public Map<String, Object> getPropertyMap() {
return propertyMap;
}
public void setPropertyMap(Map<String, Object> propertyMap) {
this.propertyMap = propertyMap;
}
}
샘플 앱에서 이 개체는 TableServiceImpl 클래스의 updateEntity 메서드에 전달됩니다. 이 메서드는 먼저 TableClient의 getEntity 메서드를 사용하여 Table API의 기존 엔터티를 로드합니다. 그런 다음, 해당 엔터티 개체를 업데이트하고 updateEntity 메서드를 사용하여 업데이트를 데이터베이스에 저장합니다. updateEntity 메서드가 개체의 현재 Etag를 사용하여 개체가 처음 로드된 이후에 변경되지 않았는지 확인하는 방법을 잘 보세요. 개의치 않고 엔터티를 업데이트하려는 경우 etag 값을 updateEntity 메서드에 전달하면 됩니다.
public void updateEntity(UpdateWeatherObject model) {
TableEntity tableEntity = tableClient.getEntity(model.getStationName(), model.getObservationDate());
Map<String, Object> propertiesMap = model.getPropertyMap();
propertiesMap.keySet().forEach(key -> tableEntity.getProperties().put(key, propertiesMap.get(key)));
tableClient.updateEntity(tableEntity);
}
엔터티 제거
테이블에서 엔터티를 제거하려면 개체의 파티션 키와 행 키를 사용하여 TableClient 개체에서 deleteEntity 메서드를 호출합니다.
public void deleteEntity(WeatherInputModel model) {
tableClient.deleteEntity(model.getStationName(),
WeatherDataUtils.formatRowKey(model.getObservationDate(), model.getObservationTime()));
}
7 - 코드 실행
샘플 애플리케이션을 실행하여 Azure Cosmos DB Tables API와 상호 작용합니다. 애플리케이션을 처음 실행하면 테이블이 비어 있기 때문에 데이터가 없습니다. 애플리케이션 맨 위에 있는 단추를 사용하여 테이블에 데이터를 추가합니다.
테이블 엔터티를 사용하여 삽입 단추를 선택하면 TableEntity 개체를 사용하여 새 행을 삽입하거나 upsert할 수 있는 대화 상자가 열립니다.
확장 가능한 데이터를 사용하여 삽입 단추를 선택하면 사용자 지정 속성이 있는 개체를 삽입할 수 있는 대화 상자가 나타나고 Azure Cosmos DB Tables API가 필요할 때 자동으로 테이블에 속성(열)을 추가하는 방법을 보여 줍니다. 사용자 지정 필드 추가 단추를 사용하여 하나 이상의 새 속성을 추가하고 이 기능을 실습해 보세요.
샘플 데이터 삽입 단추를 사용하여 일부 샘플 데이터를 Azure Cosmos DB 테이블에 로드합니다.
위쪽 메뉴에서 결과 필터링 항목을 선택하여 [결과 필터링] 페이지로 이동합니다. 이 페이지에서 필터 조건을 입력하여 필터 절을 작성하고 Azure Cosmos DB Tables API에 전달하는 방법을 보여 줍니다.
리소스 정리
샘플 애플리케이션을 마쳤으면 Azure 계정에서 이 문서와 관련된 모든 Azure 리소스를 제거해야 합니다. 이렇게 하려면 리소스 그룹을 삭제합니다.
다음을 수행하여 Azure Portal을 통해 리소스 그룹을 삭제할 수 있습니다.
| 지침 | 스크린샷 |
|---|---|
| 리소스 그룹으로 이동하려면 검색 창에 리소스 그룹의 이름을 입력합니다. 그런 다음, 리소스 그룹 탭에서 리소스 그룹의 이름을 선택합니다. | 
|
| 리소스 그룹 페이지 위쪽에 있는 도구 모음에서 리소스 그룹 삭제를 선택합니다. | 
|
리소스 그룹의 삭제를 확인하는 메시지를 표시하는 대화 상자가 화면 오른쪽에 표시됩니다.
|
|
다음 단계
이 빠른 시작에서, Azure Cosmos DB 계정을 만들고, 데이터 탐색기를 사용하여 테이블을 만들고, 앱을 실행하는 방법을 알아보았습니다. 이제 테이블용 API를 사용하여 데이터를 쿼리할 수 있습니다.