빠른 시작: Azure SDK for Go와 함께 NoSQL용 Azure Cosmos DB 사용
이 빠른 시작에서는 Go용 Azure SDK를 사용하여 기본 Azure Cosmos DB for Table 애플리케이션을 배포합니다. Azure Cosmos DB for Table은 애플리케이션이 구조화된 테이블 데이터를 클라우드에 저장할 수 있는 스키마 없는 데이터 저장소입니다. Go용 Azure SDK를 사용하여 테이블, 행을 만들고 Azure Cosmos DB 리소스 내에서 기본 작업을 수행하는 방법을 알아봅니다.
API 참조 설명서 | 라이브러리 소스 코드 | 패키지(Go) | Azure 개발자 CLI
필수 조건
- Azure Developer CLI
- Docker Desktop
Go1.21 이상
Azure 계정이 없는 경우 시작하기 전에 체험 계정을 만듭니다.
프로젝트 초기화
Azure Developer CLI(azd)를 사용하여 Table용 Azure Cosmos DB 계정을 만들고 컨테이너화된 샘플 애플리케이션을 배포합니다. 샘플 애플리케이션은 클라이언트 라이브러리를 사용하여 샘플 데이터를 관리, 만들기, 읽기 및 쿼리합니다.
빈 디렉터리에서 터미널을 엽니다.
아직 인증되지 않은 경우 .
azd auth login원하는 Azure 자격 증명을 사용하여 CLI에 인증하려면 도구에 지정된 단계를 따릅니다.azd auth login프로젝트를 초기화하려면
azd init를 사용합니다.azd init --template cosmos-db-nosql-go-quickstart초기화 중에 고유한 환경 이름을 구성합니다.
azd up을 사용하여 Azure Cosmos DB 계정을 배포합니다. Bicep 템플릿은 샘플 웹 애플리케이션도 배포합니다.azd up프로비전 프로세스 중에 구독, 원하는 위치 및 대상 리소스 그룹을 선택합니다. 프로비저닝 프로세스가 완료될 때까지 기다립니다. 이 과정은 약 5분 정도 소요됩니다.
Azure 리소스 프로비전이 완료되면 실행 중인 웹 애플리케이션에 대한 URL이 출력에 포함됩니다.
Deploying services (azd deploy) (✓) Done: Deploying service web - Endpoint: <https://[container-app-sub-domain].azurecontainerapps.io> SUCCESS: Your application was provisioned and deployed to Azure in 5 minutes 0 seconds.콘솔의 URL을 사용하여 브라우저에서 웹 애플리케이션으로 이동합니다. 실행 중인 앱의 출력을 관찰합니다.
클라이언트 라이브러리 설치
클라이언트 라이브러리는 Go를 통해 azcosmos 패키지로 사용할 수 있습니다.
터미널을 열고
/src폴더로 이동합니다.cd ./src아직 설치되지 않은 경우
go install을 사용하여azcosmos패키지를 설치합니다.go install github.com/Azure/azure-sdk-for-go/sdk/data/azcosmos또한 아직 설치되지 않은 경우
azidentity패키지를 설치합니다.go install github.com/Azure/azure-sdk-for-go/sdk/azidentitysrc/go.mod 파일을 열고 검토하여
github.com/Azure/azure-sdk-for-go/sdk/data/azcosmos및github.com/Azure/azure-sdk-for-go/sdk/azidentity항목이 모두 존재하는지 유효성을 검사합니다.
개체 모델
| 이름 | 설명 |
|---|---|
CosmosClient |
이 클래스는 기본 클라이언트 클래스이며 계정 전체의 메타데이터 또는 데이터베이스를 관리하는 데 사용됩니다. |
CosmosDatabase |
이 클래스는 계정 내의 데이터베이스를 나타냅니다. |
CosmosContainer |
이 클래스는 주로 컨테이너 또는 컨테이너 내에 저장된 항목에 대해 읽기, 업데이트 및 삭제 작업을 수행하는 데 사용됩니다. |
PartitionKey |
이 클래스는 논리 파티션 키를 나타냅니다. 이 클래스는 많은 일반적인 작업 및 쿼리에 필요합니다. |
코드 예제
템플릿의 샘플 코드는 cosmicworks라는 데이터베이스와 products라는 컨테이너를 사용합니다. products 컨테이너에는 각 제품의 이름, 범주, 수량, 고유 식별자 및 판매 플래그와 같은 세부 정보가 포함되어 있습니다. 컨테이너는 /category 속성을 논리 파티션 키로 사용합니다.
클라이언트 인증
이 샘플은 azcosmos.NewClient를 사용하여 CosmosClient의 새 인스턴스를 만들고 DefaultAzureCredential 인스턴스를 사용하여 인증합니다.
credential, err := azidentity.NewDefaultAzureCredential(nil)
if err != nil {
return err
}
clientOptions := azcosmos.ClientOptions{
EnableContentResponseOnWrite: true,
}
client, err := azcosmos.NewClient("<azure-cosmos-db-nosql-account-endpoint>", credential, &clientOptions)
if err != nil {
return err
}
데이터베이스 가져오기
client.NewDatabase를 사용하여 cosmicworks라는 기존 데이터베이스를 검색합니다.
database, err := client.NewDatabase("cosmicworks")
if err != nil {
return err
}
컨테이너 가져오기
database.NewContainer를 사용하여 기존 products 컨테이너를 검색합니다.
container, err := database.NewContainer("products")
if err != nil {
return err
}
항목 만들기
JSON으로 직렬화하려는 모든 멤버로 Go 형식을 빌드합니다. 이 예에서 형식에는 고유 식별자와 범주, 이름, 수량, 가격 및 판매에 대한 필드가 있습니다.
type Item struct {
Id string `json:"id"`
Category string `json:"category"`
Name string `json:"name"`
Quantity int `json:"quantity"`
Price float32 `json:"price"`
Clearance bool `json:"clearance"`
}
container.UpsertItem을 사용하여 컨테이너에 항목을 만듭니다. 이 방법은 항목이 이미 존재하는 경우 해당 항목을 효과적으로 바꿔 해당 항목을 "upsert"합니다.
item := Item {
Id: "aaaaaaaa-0000-1111-2222-bbbbbbbbbbbb",
Category: "gear-surf-surfboards",
Name: "Yamba Surfboard",
Quantity: 12,
Price: 850.00,
Clearance: false,
}
partitionKey := azcosmos.NewPartitionKeyString("gear-surf-surfboards")
context := context.TODO()
bytes, err := json.Marshal(item)
if err != nil {
return err
}
response, err := container.UpsertItem(context, partitionKey, bytes, nil)
if err != nil {
return err
}
항목 읽기
고유 식별자(id)와 파티션 키 필드를 모두 사용하여 포인트 읽기 작업을 수행합니다. 특정 항목을 효율적으로 검색하려면 container.ReadItem을 사용합니다.
partitionKey := azcosmos.NewPartitionKeyString("gear-surf-surfboards")
context := context.TODO()
itemId := "aaaaaaaa-0000-1111-2222-bbbbbbbbbbbb"
response, err := container.ReadItem(context, partitionKey, itemId, nil)
if err != nil {
return err
}
if response.RawResponse.StatusCode == 200 {
read_item := Item{}
err := json.Unmarshal(response.Value, &read_item)
if err != nil {
return err
}
}
쿼리 항목
container.NewQueryItemsPager를 사용하여 컨테이너의 여러 항목에 대해 쿼리를 수행합니다. 다음 매개 변수가 있는 쿼리를 사용하여 지정된 범주 내의 모든 항목을 찾습니다.
SELECT * FROM products p WHERE p.category = @category
partitionKey := azcosmos.NewPartitionKeyString("gear-surf-surfboards")
query := "SELECT * FROM products p WHERE p.category = @category"
queryOptions := azcosmos.QueryOptions{
QueryParameters: []azcosmos.QueryParameter{
{Name: "@category", Value: "gear-surf-surfboards"},
},
}
pager := container.NewQueryItemsPager(query, partitionKey, &queryOptions)
pager.NextPage를 사용하여 결과의 각 페이지를 반복하여 페이지가 매겨진 쿼리 결과를 구문 분석합니다. 각 루프 시작 시 결과가 남아 있는지 확인하려면 pager.More를 사용합니다.
items := []Item{}
for pager.More() {
response, err := pager.NextPage(context.TODO())
if err != nil {
return err
}
for _, bytes := range response.Items {
item := Item{}
err := json.Unmarshal(bytes, &item)
if err != nil {
return err
}
items = append(items, item)
}
}
리소스 정리
샘플 애플리케이션이나 리소스가 더 이상 필요하지 않으면 해당 배포와 모든 리소스를 제거합니다.
azd down