빠른 시작: .NET용 Apache Gremlin 클라이언트 라이브러리용 Azure Cosmos DB

.NET용 Azure Cosmos DB for Apache Gremlin 클라이언트 라이브러리를 시작하여 구조화되지 않은 데이터를 저장, 관리 및 쿼리합니다. 이 가이드의 단계에 따라 새 계정을 만들고, .NET 클라이언트 라이브러리를 설치하고, 계정에 연결하고, 일반적인 작업을 수행하고, 최종 샘플 데이터를 쿼리합니다.

라이브러리 소스 코드 | 패키지(NuGet)

필수 구성 요소

• Azure 구독

  • Azure 구독이 없는 경우, 시작하기 전에 무료 계정을 만드십시오.

• Azure Cloud Shell에서 최신 버전의 Azure CLI입니다.

  • CLI 참조 명령을 로컬로 실행하려면 명령을 사용하여 Azure CLI에 로그인합니다 az login .

• .NET SDK 9.0 이상

설치

먼저 이 가이드에 대한 계정 및 개발 환경을 설정합니다. 이 섹션에서는 계정을 만들고 자격 증명을 얻은 다음 개발 환경을 준비하는 프로세스를 안내합니다.

계정 만들기

먼저 Apache Gremlin 계정에 대한 API를 만듭니다. 계정이 만들어지면 데이터베이스 및 그래프 리소스를 만듭니다.

자격 증명 가져오기

이제 최근에 만든 계정에 대한 연결을 만드는 데 사용할 클라이언트 라이브러리의 암호를 가져옵니다.

개발 환경 준비

그런 다음 새 프로젝트 및 클라이언트 라이브러리를 사용하여 개발 환경을 구성합니다. 이 단계는 이 가이드의 나머지 단계로 넘어가기 전에 마지막으로 필요한 필수 구성 요소입니다.

1. 빈 폴더에서 시작합니다.

2. 새 .NET 콘솔 애플리케이션 만들기

   dotnet new console
   

3. Gremlin.Net NuGet에서 패키지를 가져옵니다.

   dotnet add package Gremlin.Net
   

4. 프로젝트를 빌드합니다.

   dotnet build
   

개체 모델

코드 예제

• 클라이언트 인증
• 데이터 삽입
• 데이터 읽기
• 쿼리 데이터

클라이언트 인증

먼저 이 가이드의 앞부분에서 수집한 자격 증명을 사용하여 클라이언트를 인증합니다.

1. IDE(통합 개발 환경)에서 Program.cs 파일을 엽니다.

2. 파일 내의 기존 콘텐츠를 삭제합니다.

3. 다음 네임스페이스에 대한 using 지시문을 추가합니다.

   • Gremlin.Net.Driver
   • Gremlin.Net.Structure.IO.GraphSON

   using Gremlin.Net.Driver;
   using Gremlin.Net.Structure.IO.GraphSON;
   

4. 이 가이드의 앞부분에서 수집된 자격 증명에 대한 문자열 변수를 만듭니다. 변수 hostname 및 primaryKey의 이름을 지정하세요.

   string hostname = "<host>";
   string primaryKey = "<key>";
   

5. GremlinServer 이전 단계에서 만든 자격 증명 및 구성 변수를 사용하여 만듭니다. 변수 이름을 지정합니다 server.

   GremlinServer server = new(
       $"{hostname}.gremlin.cosmos.azure.com",
       443,
       enableSsl: true,
       username: "/dbs/cosmicworks/colls/products",
       password: primaryKey
   );
   

6. 이제 GremlinClient 변수를 사용하고 server 구성을 기반으로 GraphSON2MessageSerializer을(를) 만드십시오.

   GremlinClient client = new(
       server,
       new GraphSON2MessageSerializer()
   );
   

데이터 삽입

다음으로 그래프에 새 꼭짓점 및 에지 데이터를 삽입합니다. 새 데이터를 만들기 전에 기존 데이터의 그래프를 지웁다.

1. 쿼리를 g.V().drop() 실행하여 그래프에서 모든 꼭짓점 및 가장자리를 지웁니다.

   await client.SubmitAsync("g.V().drop()");
   

2. 꼭짓점을 추가하는 Gremlin 쿼리를 만듭니다.

   string insertVertexQuery = """
       g.addV('product')
           .property('id', prop_id)
           .property('name', prop_name)
           .property('category', prop_category)
           .property('quantity', prop_quantity)
           .property('price', prop_price)
           .property('clearance', prop_clearance)
   """;
   

3. 단일 제품에 대한 꼭짓점을 추가합니다.

   await client.SubmitAsync(insertVertexQuery, new Dictionary<string, object>
   {
       ["prop_id"] = "aaaaaaaa-0000-1111-2222-bbbbbbbbbbbb",
       ["prop_name"] = "Yamba Surfboard",
       ["prop_category"] = "gear-surf-surfboards",
       ["prop_quantity"] = 12,
       ["prop_price"] = 850.00,
       ["prop_clearance"] = false
   });
   

4. 두 개의 꼭짓점을 추가하여 두 개의 추가 제품을 만듭니다.

   await client.SubmitAsync(insertVertexQuery, new Dictionary<string, object>
   {
       ["prop_id"] = "bbbbbbbb-1111-2222-3333-cccccccccccc",
       ["prop_name"] = "Montau Turtle Surfboard",
       ["prop_category"] = "gear-surf-surfboards",
       ["prop_quantity"] = 5,
       ["prop_price"] = 600.00,
       ["prop_clearance"] = true
   });
   
   await client.SubmitAsync(insertVertexQuery, new Dictionary<string, object>
   {
       ["prop_id"] = "cccccccc-2222-3333-4444-dddddddddddd",
       ["prop_name"] = "Noosa Surfboard",
       ["prop_category"] = "gear-surf-surfboards",
       ["prop_quantity"] = 31,
       ["prop_price"] = 1100.00,
       ["prop_clearance"] = false
   });
   

5. 에지를 추가하는 다른 Gremlin 쿼리를 만듭니다.

   string insertEdgeQuery = """
       g.V([prop_partition_key, prop_source_id])
           .addE('replaces')
           .to(g.V([prop_partition_key, prop_target_id]))
   """;
   

6. 두 개의 가장자리를 추가합니다.

   await client.SubmitAsync(insertEdgeQuery, new Dictionary<string, object>
   {
       ["prop_partition_key"] = "gear-surf-surfboards",
       ["prop_source_id"] = "bbbbbbbb-1111-2222-3333-cccccccccccc",
       ["prop_target_id"] = "aaaaaaaa-0000-1111-2222-bbbbbbbbbbbb"
   });
   
   await client.SubmitAsync(insertEdgeQuery, new Dictionary<string, object>
   {
       ["prop_partition_key"] = "gear-surf-surfboards",
       ["prop_source_id"] = "bbbbbbbb-1111-2222-3333-cccccccccccc",
       ["prop_target_id"] = "cccccccc-2222-3333-4444-dddddddddddd"
   });
   

데이터 읽기

그런 다음, 이전에 그래프에 삽입된 데이터를 읽습니다.

1. 고유 식별자 및 파티션 키 값을 사용하여 꼭짓점을 읽는 쿼리를 만듭니다.

   string readVertexQuery = "g.V([prop_partition_key, prop_id])";
   

2. 그런 다음 필요한 매개 변수를 제공하여 꼭짓점을 읽습니다.

   ResultSet<Dictionary<string, object>> readResults = await client.SubmitAsync<Dictionary<string, object>>(readVertexQuery, new Dictionary<string, object>
   {
       ["prop_partition_key"] = "gear-surf-surfboards",
       ["prop_id"] = "aaaaaaaa-0000-1111-2222-bbbbbbbbbbbb"
   });
   
   Dictionary<string, object> matchedItem = readResults.Single();
   

쿼리 데이터

마지막으로, 쿼리를 사용하여 그래프에서 특정 순회 또는 필터와 일치하는 모든 데이터를 찾습니다.

1. 특정 꼭짓점에서 시작하여 바깥쪽으로 뻗어 나가는 모든 꼭짓점을 찾는 쿼리를 만듭니다.

   string findVerticesQuery = """
       g.V().hasLabel('product')
           .has('category', prop_partition_key)
           .has('name', prop_name)
           .outE('replaces').inV()
   """;
   

2. 제품을 지정하는 쿼리를 실행합니다 Montau Turtle Surfboard .

   ResultSet<Dictionary<string, object>> findResults = await client.SubmitAsync<Dictionary<string, object>>(findVerticesQuery, new Dictionary<string, object>
   {
       ["prop_partition_key"] = "gear-surf-surfboards",
       ["prop_name"] = "Montau Turtle Surfboard"
   });
   

3. 쿼리 결과를 반복합니다.

   foreach (Dictionary<string, object> result in findResults)
   {
       // Do something here with each result
   }
   

코드 실행

애플리케이션 디렉터리의 터미널을 사용하여 새로 만든 애플리케이션을 실행합니다.

dotnet run

리소스 정리

계정이 더 이상 필요하지 않은 경우 리소스를 삭제하여 Azure 구독에서 계정을 제거합니다.

az cosmosdb delete \
    --resource-group "<resource-group-name>" \
    --name "<account-name>"