Integrace služby Azure Cosmos DB pro Gremlin s konektorem služby

Tato stránka ukazuje podporované metody ověřování a klienty a ukazuje ukázkový kód, který můžete použít k připojení služby Azure Cosmos DB pro Apache Gremlin k dalším cloudovým službám pomocí konektoru služby. Stále se můžete připojit ke službě Azure Cosmos DB pro Gremlin v jiných programovacích jazycích bez použití konektoru služby. Tato stránka také zobrazuje výchozí názvy proměnných prostředí a hodnoty, které získáte při vytváření připojení služby.

Podporované výpočetní služby

Konektor služby se dá použít k připojení následujících výpočetních služeb ke službě Azure Cosmos DB pro Apache Gremlin:

• Azure App Service
• Azure Container Apps
• Azure Functions
• Azure Kubernetes Service (AKS)
• Azure Spring Apps

Podporované typy ověřování a typy klientů

Následující tabulka ukazuje, které kombinace typů klientů a metod ověřování se podporují pro připojení výpočetní služby ke službě Azure Cosmos DB pro Apache Gremlin pomocí konektoru služby. "Ano" označuje, že kombinace je podporována, zatímco "Ne" označuje, že není podporována.

Typ klienta	Spravovaná identita přiřazená systémem	Spravovaná identita přiřazená uživatelem	Tajný kód / připojovací řetězec	Instanční objekt
.NET	Ano	Ano	Ano	Yes
Java	Ano	Ano	Ano	Yes
Node.js	Ano	Ano	Ano	Yes
PHP	Ano	Ano	Ano	Yes
Python	Ano	Ano	Ano	Yes
Go	Ano	Ano	Ano	Yes
Nic	Ano	Ano	Ano	Yes

Tato tabulka označuje, že jsou podporovány všechny kombinace typů klientů a metod ověřování v tabulce. Všechny typy klientů můžou k připojení ke službě Azure Cosmos DB pro Apache Gremlin použít některou z metod ověřování pomocí konektoru služby.

Výchozí názvy proměnných prostředí nebo vlastnosti aplikace a ukázkový kód

Pomocí níže uvedených podrobností o připojení připojte výpočetní služby ke službě Azure Cosmos DB pro Apache Gremlin. V každém příkladu níže nahraďte zástupné texty <Azure-Cosmos-DB-account>, <database>, <collection or graphs>, <password><username>, <resource-group-name>, ,<client-secret><subscription-ID><client-ID> , a <tenant-id> vlastními informacemi. Další informace o konvencích vytváření názvů najdete v interním článku o konektoru služby.

Spravovaná identita přiřazená systémem

Výchozí název proměnné prostředí	Popis	Příklad hodnoty
AZURE_COSMOS_LISTKEYURL	Adresa URL pro získání připojovací řetězec	https://management.azure.com/subscriptions/<subscription-ID>/resourceGroups/<resource-group-name>/providers/Microsoft.DocumentDB/databaseAccounts/<Azure-Cosmos-DB-account>/listKeys?api-version=2021-04-15
AZURE_COSMOS_SCOPE	Rozsah spravované identity	https://management.azure.com/.default
AZURE_COSMOS_RESOURCEENDPOINT	Váš koncový bod prostředku	https://<Azure-Cosmos-DB-account>.documents.azure.com:443/
AZURE_COSMOS_HOSTNAME	Jedinečný identifikátor prostředku Gremlin (UFI)	<Azure-Cosmos-DB-account>.gremlin.cosmos.azure.com
AZURE_COSMOS_PORT	Port připojení	443
AZURE_COSMOS_USERNAME	Vaše uživatelské jméno	/dbs/<database>/colls/<collection or graphs>

Ukázkový kód

Projděte si následující kroky a kód a připojte se ke službě Azure Cosmos DB pro Gremlin pomocí spravované identity přiřazené systémem.

.NET

1. Nainstalujte závislosti.

   dotnet add package Gremlin.Net
   dotnet add package Azure.Identity
   

2. Získejte přístupový token pro spravovanou identitu nebo instanční objekt pomocí klientské knihovny Azure.Identity. Použijte přístupový token a AZURE_COSMOS_LISTKEYURL získejte heslo. Získejte informace o připojení z proměnných prostředí přidaných konektorem služby a připojte se ke službě Azure Cosmos DB pro Apache Gremlin. Při použití následujícího kódu odkomentujte část fragmentu kódu pro typ ověřování, který chcete použít.

   using System;
   using System.Security.Authentication;
   using System.Net.Security;
   using System.Net.Http;
   using System.Security.Authentication;
   using System.Threading.Tasks;
   using System;
   using Gremlin.Net.Driver;
   using Azure.Identity;
   
   var gremlinEndpoint = Environment.GetEnvironmentVariable("AZURE_COSMOS_RESOURCEENDPOINT");
   var userName = Environment.GetEnvironmentVariable("AZURE_COSMOS_USERNAME");
   var gremlinPort = Int32.Parse(Environment.GetEnvironmentVariable("AZURE_COSMOS_PORT"));
   var listKeyUrl = Environment.GetEnvironmentVariable("AZURE_COSMOS_LISTKEYURL");
   var scope = Environment.GetEnvironmentVariable("AZURE_COSMOS_SCOPE");
   
   // Uncomment the following lines corresponding to the authentication type you want to use.
   // For system-assigned identity.
   // var tokenProvider = new DefaultAzureCredential();
   
   // For user-assigned identity.
   // var tokenProvider = new DefaultAzureCredential(
   //     new DefaultAzureCredentialOptions
   //     {
   //         ManagedIdentityClientId = Environment.GetEnvironmentVariable("AZURE_COSMOS_CLIENTID");
   //     }
   // );
   
   // For service principal.
   // var tenantId = Environment.GetEnvironmentVariable("AZURE_COSMOS_TENANTID");
   // var clientId = Environment.GetEnvironmentVariable("AZURE_COSMOS_CLIENTID");
   // var clientSecret = Environment.GetEnvironmentVariable("AZURE_COSMOS_CLIENTSECRET");
   // var tokenProvider = new ClientSecretCredential(tenantId, clientId, clientSecret);
   
   // Acquire the access token. 
   AccessToken accessToken = await tokenProvider.GetTokenAsync(
       new TokenRequestContext(scopes: new string[]{ scope }));
   
   // Get the password.
   var httpClient = new HttpClient();
   httpClient.DefaultRequestHeaders.Add("Authorization", $"Bearer {accessToken.Token}");
   var response = await httpClient.POSTAsync(listKeyUrl);
   var responseBody = await response.Content.ReadAsStringAsync();
   var keys = JsonConvert.DeserializeObject<Dictionary<string, string>>(responseBody);
   var password = keys["primaryMasterKey"];
   
   // Connect to Azure Cosmos DB for Apache Gremlin
   var server = new GremlinServer(
       hostname: gremlinEndpoint,
       port: gremlinPort,
       username: userName,
       password: password,
       enableSsl: true
   );
   
   using var client = new GremlinClient(
       gremlinServer: server,
       messageSerializer: new Gremlin.Net.Structure.IO.GraphSON.GraphSON2MessageSerializer()
   );        
   
   

Java

1. Do souboru pom.xml přidejte následující závislosti:

   <dependency>
     <groupId>org.apache.tinkerpop</groupId>
     <artifactId>gremlin-driver</artifactId>
     <version>3.4.13</version>
   </dependency>
   <dependency>
       <groupId>com.azure</groupId>
       <artifactId>azure-identity</artifactId>
       <version>1.1.5</version>
   </dependency>
   

2. Získejte přístupový token pro spravovanou identitu nebo instanční objekt pomocí azure-identity. Použijte přístupový token a AZURE_COSMOS_LISTKEYURL získejte heslo. Získejte informace o připojení z proměnných prostředí přidaných konektorem služby a připojte se ke službě Azure Cosmos DB pro Apache Gremlin. Při použití následujícího kódu odkomentujte část fragmentu kódu pro typ ověřování, který chcete použít.

   import org.apache.tinkerpop.gremlin.driver.Client;
   import org.apache.tinkerpop.gremlin.driver.Cluster;
   import javax.net.ssl.*;
   import java.net.InetSocketAddress;
   import com.azure.identity.*;
   import com.azure.core.credential.*;
   import java.net.http.*;
   import java.net.URI;
   
   int gremlinPort = Integer.parseInt(System.getenv("AZURE_COSMOS_PORT"));
   String username = System.getenv("AZURE_COSMOS_USERNAME");
   String gremlinEndpoint = System.getenv("AZURE_COSMOS_RESOURCEENDPOINT");
   String listKeyUrl = System.getenv("AZURE_COSMOS_LISTKEYURL");
   String scope = System.getenv("AZURE_COSMOS_SCOPE");
   
   // Uncomment the following lines corresponding to the authentication type you want to use.
   // For system managed identity.
   // DefaultAzureCredential defaultCredential = new DefaultAzureCredentialBuilder().build();
   
   // For user assigned managed identity.
   // DefaultAzureCredential defaultCredential = new DefaultAzureCredentialBuilder()
   //     .managedIdentityClientId(System.getenv("AZURE_COSMOS_CLIENTID"))
   //     .build();
   
   // For service principal.
   // ClientSecretCredential defaultCredential = new ClientSecretCredentialBuilder()
   //   .clientId(System.getenv("AZURE_COSMOS_CLIENTID"))
   //   .clientSecret(System.getenv("AZURE_COSMOS_CLIENTSECRET"))
   //   .tenantId(System.getenv("AZURE_COSMOS_TENANTID"))
   //   .build();
   
   // Get the access token.
   AccessToken accessToken = defaultCredential.getToken(new TokenRequestContext().addScopes(new String[]{ scope })).block();
   String token = accessToken.getToken();
   
   // Get the password.
   HttpClient client = HttpClient.newBuilder().build();
   HttpRequest request = HttpRequest.newBuilder()
       .uri(new URI(listKeyUrl))
       .header("Authorization", "Bearer " + token)
       .POST()
       .build();
   HttpResponse<String> response = client.send(request, HttpResponse.BodyHandlers.ofString());
   JSONParser parser = new JSONParser();
   JSONObject responseBody = parser.parse(response.body());
   String gremlinPassword = responseBody.get("primaryMasterKey");
   
   // Connect to Azure Cosmos DB for Apache Gremlin
   Cluster cluster;
   Client client;
   
   cluster = Cluster.addContactPoint​(gremlinEndpoint).port(gremlinPort).credentials(username, password).create();
   

Python

1. Nainstalujte závislosti.

   pip install gremlinpython
   

2. Slouží azure-identity k ověření pomocí spravované identity nebo instančního objektu a odeslání požadavku na AZURE_COSMOS_LISTKEYURL získání hesla. Získejte informace o připojení z proměnných prostředí přidaných konektorem služby a připojte se ke službě Azure Cosmos DB pro Apache Gremlin. Při použití následujícího kódu odkomentujte část fragmentu kódu pro typ ověřování, který chcete použít.

   from gremlin_python.driver import client, serializer
   import requests
   from azure.identity import ManagedIdentityCredential, ClientSecretCredential
   
   username = os.getenv('AZURE_COSMOS_USERNAME')
   endpoint = os.getenv('AZURE_COSMOS_RESOURCEENDPOINT')
   port = os.getenv('AZURE_COSMOS_PORT')
   listKeyUrl = os.getenv('AZURE_COSMOS_LISTKEYURL')
   scope = os.getenv('AZURE_COSMOS_SCOPE')
   
   # Uncomment the following lines corresponding to the authentication type you want to use.
   # For system-assigned managed identity
   # cred = ManagedIdentityCredential()
   
   # For user-assigned managed identity
   # managed_identity_client_id = os.getenv('AZURE_COSMOS_CLIENTID')
   # cred = ManagedIdentityCredential(client_id=managed_identity_client_id)
   
   # For service principal
   # tenant_id = os.getenv('AZURE_COSMOS_TENANTID')
   # client_id = os.getenv('AZURE_COSMOS_CLIENTID')
   # client_secret = os.getenv('AZURE_COSMOS_CLIENTSECRET')
   # cred = ClientSecretCredential(tenant_id=tenant_id, client_id=client_id, client_secret=client_secret)
   
   # Get the password 
   session = requests.Session()
   token = cred.get_token(scope)
   response = session.post(listKeyUrl, headers={"Authorization": "Bearer {}".format(token.token)})
   keys_dict = response.json()
   password = keys_dict['primaryMasterKey']
   
   # Connect to Azure Cosmos DB for Apache Gremlin.
   client = client.Client(
       url=endpoint,
       traversal_source="g",
       username=username,
       password=password,
       message_serializer=serializer.GraphSONSerializersV2d0(),
   )
   

Přejít

1. Nainstalujte závislosti.

   go get github.com/Azure/azure-sdk-for-go/sdk/azidentity
   go get github.com/go-gremlin/gremlin
   

2. V kódu získejte přístupový token pomocí azidentitya pak ho použijte k získání hesla. Získejte informace o připojení z proměnné prostředí přidané konektorem služby a připojte se ke službě Azure Cosmos DB pro Apache Gremlin. Při použití následujícího kódu odkomentujte část fragmentu kódu pro typ ověřování, který chcete použít.

   import (
       "fmt"
       "os"
       "context"
       "log"
       "io/ioutil"
       "encoding/json"
   
       "github.com/go-gremlin/gremlin"
       "github.com/Azure/azure-sdk-for-go/sdk/azidentity"
   )
   
   func main() {
       username = os.Getenv("AZURE_COSMOS_USERNAME")
       endpoint = os.getenv("AZURE_COSMOS_RESOURCEENDPOINT")
       port = os.getenv("AZURE_COSMOS_PORT")
       listKeyUrl = os.Getenv("AZURE_COSMOS_LISTKEYURL")
       scope = os.Getenv("AZURE_COSMOS_SCOPE")
   
       // Uncomment the following lines corresponding to the authentication type you want to use.
       // For system-assigned identity.
       // cred, err := azidentity.NewDefaultAzureCredential(nil)
   
       // For user-assigned identity.
       // clientid := os.Getenv("AZURE_COSMOS_CLIENTID")
       // azidentity.ManagedIdentityCredentialOptions.ID := clientid
       // options := &azidentity.ManagedIdentityCredentialOptions{ID: clientid}
       // cred, err := azidentity.NewManagedIdentityCredential(options)
   
       // For service principal.
       // clientid := os.Getenv("AZURE_COSMOS_CLIENTID")
       // tenantid := os.Getenv("AZURE_COSMOS_TENANTID")
       // clientsecret := os.Getenv("AZURE_COSMOS_CLIENTSECRET")
       // cred, err := azidentity.NewClientSecretCredential(tenantid, clientid, clientsecret, &azidentity.ClientSecretCredentialOptions{})
   
       // Acquire the access token.
       ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
       token, err := cred.GetToken(ctx, policy.TokenRequestOptions{
           Scopes: []string{scope},
       })
   
       // Acquire the connection string.
       client := &http.Client{}
       req, err := http.NewRequest("POST", listKeyUrl, nil)
       req.Header.Add("Authorization", "Bearer " + token.Token)
       resp, err := client.Do(req)
       body, err := ioutil.ReadAll(resp.Body)
       var result map[string]interface{}
       json.Unmarshal(body, &result)
       password, err := result["primaryMasterKey"];
   
       auth := gremlin.OptAuthUserPass(username, password)
        client, err := gremlin.NewClient(endpoint, auth)
   }
   

NodeJS

1. Nainstalujte závislosti.

   npm install gremlin
   npm install --save @azure/identity
   

2. V kódu získejte přístupový token pomocí @azure/identitya pak ho použijte k získání hesla. Získejte informace o připojení z proměnné prostředí přidané konektorem služby a připojte se ke službě Azure Cosmos DB pro Apache Gremlin. Při použití následujícího kódu odkomentujte část fragmentu kódu pro typ ověřování, který chcete použít.

   import { DefaultAzureCredential,ClientSecretCredential } from "@azure/identity";
   import gremlin from 'gremlin'
   const axios = require('axios');
   
   let username = process.env.AZURE_COSMOS_USERNAME;
   let endpoint = process.env.AZURE_COSMOS_RESOURCEENDPOINT;
   let port = process.env.AZURE_COSMOS_PORT;
   let listKeyUrl = process.env.AZURE_COSMOS_LISTKEYURL;
   let scope = process.env.AZURE_COSMOS_SCOPE;
   
   // Uncomment the following lines corresponding to the authentication type you want to use.  
   // For system-assigned identity.
   // const credential = new DefaultAzureCredential();
   
   // For user-assigned identity.
   // const clientId = process.env.AZURE_COSMOS_CLIENTID;
   // const credential = new DefaultAzureCredential({
   //     managedIdentityClientId: clientId
   // });
   
   // For service principal.
   // const tenantId = process.env.AZURE_COSMOS_TENANTID;
   // const clientId = process.env.AZURE_COSMOS_CLIENTID;
   // const clientSecret = process.env.AZURE_COSMOS_CLIENTSECRET;
   
   // Acquire the access token.
   var accessToken = await credential.getToken(scope);
   
   // Get the password.
   const config = {
       method: 'post',
       url: listKeyUrl,
       headers: { 
         'Authorization': `Bearer ${accessToken.token}`
       }
   };
   const response = await axios(config);
   const keysDict = response.data;
   const password = keysDict['primaryMasterKey'];
   
   const credentials = new gremlin.driver.auth.PlainTextSaslAuthenticator(
     username,
     password
   )
   
   const client = new gremlin.driver.Client(
     endpoint,
     {
       credentials,
       traversalsource: 'g',
       rejectUnauthorized: true,
       mimeType: 'application/vnd.gremlin-v2.0+json'
     }
   )
   
   client.open()
   

PHP

Získejte přístupový token se spravovanou identitou nebo instančním objektem pro získání primárního klíče služby Azure Cosmos DB pro Gremlin voláním rozhraní REST API na adrese AZURE_COSMOS_LISTKEYURL.

$endpoint = getenv('AZURE_COSMOS_RESOURCEENDPOINT');
$username = getenv('AZURE_COSMOS_USERNAME');
$port = getenv('AZURE_COSMOS_PORT');

$db = new Connection([
    'host' => $endpoint,
    'username' => $username,
    'password' => $password,
    'port' => $port,
    'ssl' => TRUE
]);

Další

V jiných jazycích můžete použít koncový bod Apache Gremlin a další vlastnosti, které Konektor služby nastaví na proměnné prostředí pro připojení k prostředku Azure Cosmos DB for Apache Gremlin. Podrobnosti o proměnné prostředí najdete v tématu Integrace služby Azure Cosmos DB pro Apache Gremlin s konektorem služby.

Spravovaná identita přiřazená uživatelem

Výchozí název proměnné prostředí	Popis	Příklad hodnoty
AZURE_COSMOS_LISTKEYURL	Adresa URL pro získání připojovací řetězec	https://management.azure.com/subscriptions/<subscription-ID>/resourceGroups/<resource-group-name>/providers/Microsoft.DocumentDB/databaseAccounts/<Azure-Cosmos-DB-account>/listKeys?api-version=2021-04-15
AZURE_COSMOS_SCOPE	Rozsah spravované identity	https://management.azure.com/.default
AZURE_COSMOS_RESOURCEENDPOINT	Váš koncový bod prostředku	https://<Azure-Cosmos-DB-account>.documents.azure.com:443/
AZURE_COSMOS_HOSTNAME	Jedinečný identifikátor prostředku Gremlin (UFI)	<Azure-Cosmos-DB-account>.gremlin.cosmos.azure.com
AZURE_COSMOS_PORT	Port připojení	443
AZURE_COSMOS_USERNAME	Vaše uživatelské jméno	/dbs/<database>/colls/<collection or graphs>
AZURE_CLIENTID	ID klienta	<client_ID>

Ukázkový kód

Pokud se chcete připojit ke službě Azure Cosmos DB pro Gremlin pomocí spravované identity přiřazené uživatelem, projděte si následující postup a kód.

.NET

1. Nainstalujte závislosti.

   dotnet add package Gremlin.Net
   dotnet add package Azure.Identity
   

2. Získejte přístupový token pro spravovanou identitu nebo instanční objekt pomocí klientské knihovny Azure.Identity. Použijte přístupový token a AZURE_COSMOS_LISTKEYURL získejte heslo. Získejte informace o připojení z proměnných prostředí přidaných konektorem služby a připojte se ke službě Azure Cosmos DB pro Apache Gremlin. Při použití následujícího kódu odkomentujte část fragmentu kódu pro typ ověřování, který chcete použít.

   using System;
   using System.Security.Authentication;
   using System.Net.Security;
   using System.Net.Http;
   using System.Security.Authentication;
   using System.Threading.Tasks;
   using System;
   using Gremlin.Net.Driver;
   using Azure.Identity;
   
   var gremlinEndpoint = Environment.GetEnvironmentVariable("AZURE_COSMOS_RESOURCEENDPOINT");
   var userName = Environment.GetEnvironmentVariable("AZURE_COSMOS_USERNAME");
   var gremlinPort = Int32.Parse(Environment.GetEnvironmentVariable("AZURE_COSMOS_PORT"));
   var listKeyUrl = Environment.GetEnvironmentVariable("AZURE_COSMOS_LISTKEYURL");
   var scope = Environment.GetEnvironmentVariable("AZURE_COSMOS_SCOPE");
   
   // Uncomment the following lines corresponding to the authentication type you want to use.
   // For system-assigned identity.
   // var tokenProvider = new DefaultAzureCredential();
   
   // For user-assigned identity.
   // var tokenProvider = new DefaultAzureCredential(
   //     new DefaultAzureCredentialOptions
   //     {
   //         ManagedIdentityClientId = Environment.GetEnvironmentVariable("AZURE_COSMOS_CLIENTID");
   //     }
   // );
   
   // For service principal.
   // var tenantId = Environment.GetEnvironmentVariable("AZURE_COSMOS_TENANTID");
   // var clientId = Environment.GetEnvironmentVariable("AZURE_COSMOS_CLIENTID");
   // var clientSecret = Environment.GetEnvironmentVariable("AZURE_COSMOS_CLIENTSECRET");
   // var tokenProvider = new ClientSecretCredential(tenantId, clientId, clientSecret);
   
   // Acquire the access token. 
   AccessToken accessToken = await tokenProvider.GetTokenAsync(
       new TokenRequestContext(scopes: new string[]{ scope }));
   
   // Get the password.
   var httpClient = new HttpClient();
   httpClient.DefaultRequestHeaders.Add("Authorization", $"Bearer {accessToken.Token}");
   var response = await httpClient.POSTAsync(listKeyUrl);
   var responseBody = await response.Content.ReadAsStringAsync();
   var keys = JsonConvert.DeserializeObject<Dictionary<string, string>>(responseBody);
   var password = keys["primaryMasterKey"];
   
   // Connect to Azure Cosmos DB for Apache Gremlin
   var server = new GremlinServer(
       hostname: gremlinEndpoint,
       port: gremlinPort,
       username: userName,
       password: password,
       enableSsl: true
   );
   
   using var client = new GremlinClient(
       gremlinServer: server,
       messageSerializer: new Gremlin.Net.Structure.IO.GraphSON.GraphSON2MessageSerializer()
   );        
   
   

Java

1. Do souboru pom.xml přidejte následující závislosti:

   <dependency>
     <groupId>org.apache.tinkerpop</groupId>
     <artifactId>gremlin-driver</artifactId>
     <version>3.4.13</version>
   </dependency>
   <dependency>
       <groupId>com.azure</groupId>
       <artifactId>azure-identity</artifactId>
       <version>1.1.5</version>
   </dependency>
   

2. Získejte přístupový token pro spravovanou identitu nebo instanční objekt pomocí azure-identity. Použijte přístupový token a AZURE_COSMOS_LISTKEYURL získejte heslo. Získejte informace o připojení z proměnných prostředí přidaných konektorem služby a připojte se ke službě Azure Cosmos DB pro Apache Gremlin. Při použití následujícího kódu odkomentujte část fragmentu kódu pro typ ověřování, který chcete použít.

   import org.apache.tinkerpop.gremlin.driver.Client;
   import org.apache.tinkerpop.gremlin.driver.Cluster;
   import javax.net.ssl.*;
   import java.net.InetSocketAddress;
   import com.azure.identity.*;
   import com.azure.core.credential.*;
   import java.net.http.*;
   import java.net.URI;
   
   int gremlinPort = Integer.parseInt(System.getenv("AZURE_COSMOS_PORT"));
   String username = System.getenv("AZURE_COSMOS_USERNAME");
   String gremlinEndpoint = System.getenv("AZURE_COSMOS_RESOURCEENDPOINT");
   String listKeyUrl = System.getenv("AZURE_COSMOS_LISTKEYURL");
   String scope = System.getenv("AZURE_COSMOS_SCOPE");
   
   // Uncomment the following lines corresponding to the authentication type you want to use.
   // For system managed identity.
   // DefaultAzureCredential defaultCredential = new DefaultAzureCredentialBuilder().build();
   
   // For user assigned managed identity.
   // DefaultAzureCredential defaultCredential = new DefaultAzureCredentialBuilder()
   //     .managedIdentityClientId(System.getenv("AZURE_COSMOS_CLIENTID"))
   //     .build();
   
   // For service principal.
   // ClientSecretCredential defaultCredential = new ClientSecretCredentialBuilder()
   //   .clientId(System.getenv("AZURE_COSMOS_CLIENTID"))
   //   .clientSecret(System.getenv("AZURE_COSMOS_CLIENTSECRET"))
   //   .tenantId(System.getenv("AZURE_COSMOS_TENANTID"))
   //   .build();
   
   // Get the access token.
   AccessToken accessToken = defaultCredential.getToken(new TokenRequestContext().addScopes(new String[]{ scope })).block();
   String token = accessToken.getToken();
   
   // Get the password.
   HttpClient client = HttpClient.newBuilder().build();
   HttpRequest request = HttpRequest.newBuilder()
       .uri(new URI(listKeyUrl))
       .header("Authorization", "Bearer " + token)
       .POST()
       .build();
   HttpResponse<String> response = client.send(request, HttpResponse.BodyHandlers.ofString());
   JSONParser parser = new JSONParser();
   JSONObject responseBody = parser.parse(response.body());
   String gremlinPassword = responseBody.get("primaryMasterKey");
   
   // Connect to Azure Cosmos DB for Apache Gremlin
   Cluster cluster;
   Client client;
   
   cluster = Cluster.addContactPoint​(gremlinEndpoint).port(gremlinPort).credentials(username, password).create();
   

Python

1. Nainstalujte závislosti.

   pip install gremlinpython
   

2. Slouží azure-identity k ověření pomocí spravované identity nebo instančního objektu a odeslání požadavku na AZURE_COSMOS_LISTKEYURL získání hesla. Získejte informace o připojení z proměnných prostředí přidaných konektorem služby a připojte se ke službě Azure Cosmos DB pro Apache Gremlin. Při použití následujícího kódu odkomentujte část fragmentu kódu pro typ ověřování, který chcete použít.

   from gremlin_python.driver import client, serializer
   import requests
   from azure.identity import ManagedIdentityCredential, ClientSecretCredential
   
   username = os.getenv('AZURE_COSMOS_USERNAME')
   endpoint = os.getenv('AZURE_COSMOS_RESOURCEENDPOINT')
   port = os.getenv('AZURE_COSMOS_PORT')
   listKeyUrl = os.getenv('AZURE_COSMOS_LISTKEYURL')
   scope = os.getenv('AZURE_COSMOS_SCOPE')
   
   # Uncomment the following lines corresponding to the authentication type you want to use.
   # For system-assigned managed identity
   # cred = ManagedIdentityCredential()
   
   # For user-assigned managed identity
   # managed_identity_client_id = os.getenv('AZURE_COSMOS_CLIENTID')
   # cred = ManagedIdentityCredential(client_id=managed_identity_client_id)
   
   # For service principal
   # tenant_id = os.getenv('AZURE_COSMOS_TENANTID')
   # client_id = os.getenv('AZURE_COSMOS_CLIENTID')
   # client_secret = os.getenv('AZURE_COSMOS_CLIENTSECRET')
   # cred = ClientSecretCredential(tenant_id=tenant_id, client_id=client_id, client_secret=client_secret)
   
   # Get the password 
   session = requests.Session()
   token = cred.get_token(scope)
   response = session.post(listKeyUrl, headers={"Authorization": "Bearer {}".format(token.token)})
   keys_dict = response.json()
   password = keys_dict['primaryMasterKey']
   
   # Connect to Azure Cosmos DB for Apache Gremlin.
   client = client.Client(
       url=endpoint,
       traversal_source="g",
       username=username,
       password=password,
       message_serializer=serializer.GraphSONSerializersV2d0(),
   )
   

Přejít

1. Nainstalujte závislosti.

   go get github.com/Azure/azure-sdk-for-go/sdk/azidentity
   go get github.com/go-gremlin/gremlin
   

2. V kódu získejte přístupový token pomocí azidentitya pak ho použijte k získání hesla. Získejte informace o připojení z proměnné prostředí přidané konektorem služby a připojte se ke službě Azure Cosmos DB pro Apache Gremlin. Při použití následujícího kódu odkomentujte část fragmentu kódu pro typ ověřování, který chcete použít.

   import (
       "fmt"
       "os"
       "context"
       "log"
       "io/ioutil"
       "encoding/json"
   
       "github.com/go-gremlin/gremlin"
       "github.com/Azure/azure-sdk-for-go/sdk/azidentity"
   )
   
   func main() {
       username = os.Getenv("AZURE_COSMOS_USERNAME")
       endpoint = os.getenv("AZURE_COSMOS_RESOURCEENDPOINT")
       port = os.getenv("AZURE_COSMOS_PORT")
       listKeyUrl = os.Getenv("AZURE_COSMOS_LISTKEYURL")
       scope = os.Getenv("AZURE_COSMOS_SCOPE")
   
       // Uncomment the following lines corresponding to the authentication type you want to use.
       // For system-assigned identity.
       // cred, err := azidentity.NewDefaultAzureCredential(nil)
   
       // For user-assigned identity.
       // clientid := os.Getenv("AZURE_COSMOS_CLIENTID")
       // azidentity.ManagedIdentityCredentialOptions.ID := clientid
       // options := &azidentity.ManagedIdentityCredentialOptions{ID: clientid}
       // cred, err := azidentity.NewManagedIdentityCredential(options)
   
       // For service principal.
       // clientid := os.Getenv("AZURE_COSMOS_CLIENTID")
       // tenantid := os.Getenv("AZURE_COSMOS_TENANTID")
       // clientsecret := os.Getenv("AZURE_COSMOS_CLIENTSECRET")
       // cred, err := azidentity.NewClientSecretCredential(tenantid, clientid, clientsecret, &azidentity.ClientSecretCredentialOptions{})
   
       // Acquire the access token.
       ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
       token, err := cred.GetToken(ctx, policy.TokenRequestOptions{
           Scopes: []string{scope},
       })
   
       // Acquire the connection string.
       client := &http.Client{}
       req, err := http.NewRequest("POST", listKeyUrl, nil)
       req.Header.Add("Authorization", "Bearer " + token.Token)
       resp, err := client.Do(req)
       body, err := ioutil.ReadAll(resp.Body)
       var result map[string]interface{}
       json.Unmarshal(body, &result)
       password, err := result["primaryMasterKey"];
   
       auth := gremlin.OptAuthUserPass(username, password)
        client, err := gremlin.NewClient(endpoint, auth)
   }
   

NodeJS

1. Nainstalujte závislosti.

   npm install gremlin
   npm install --save @azure/identity
   

2. V kódu získejte přístupový token pomocí @azure/identitya pak ho použijte k získání hesla. Získejte informace o připojení z proměnné prostředí přidané konektorem služby a připojte se ke službě Azure Cosmos DB pro Apache Gremlin. Při použití následujícího kódu odkomentujte část fragmentu kódu pro typ ověřování, který chcete použít.

   import { DefaultAzureCredential,ClientSecretCredential } from "@azure/identity";
   import gremlin from 'gremlin'
   const axios = require('axios');
   
   let username = process.env.AZURE_COSMOS_USERNAME;
   let endpoint = process.env.AZURE_COSMOS_RESOURCEENDPOINT;
   let port = process.env.AZURE_COSMOS_PORT;
   let listKeyUrl = process.env.AZURE_COSMOS_LISTKEYURL;
   let scope = process.env.AZURE_COSMOS_SCOPE;
   
   // Uncomment the following lines corresponding to the authentication type you want to use.  
   // For system-assigned identity.
   // const credential = new DefaultAzureCredential();
   
   // For user-assigned identity.
   // const clientId = process.env.AZURE_COSMOS_CLIENTID;
   // const credential = new DefaultAzureCredential({
   //     managedIdentityClientId: clientId
   // });
   
   // For service principal.
   // const tenantId = process.env.AZURE_COSMOS_TENANTID;
   // const clientId = process.env.AZURE_COSMOS_CLIENTID;
   // const clientSecret = process.env.AZURE_COSMOS_CLIENTSECRET;
   
   // Acquire the access token.
   var accessToken = await credential.getToken(scope);
   
   // Get the password.
   const config = {
       method: 'post',
       url: listKeyUrl,
       headers: { 
         'Authorization': `Bearer ${accessToken.token}`
       }
   };
   const response = await axios(config);
   const keysDict = response.data;
   const password = keysDict['primaryMasterKey'];
   
   const credentials = new gremlin.driver.auth.PlainTextSaslAuthenticator(
     username,
     password
   )
   
   const client = new gremlin.driver.Client(
     endpoint,
     {
       credentials,
       traversalsource: 'g',
       rejectUnauthorized: true,
       mimeType: 'application/vnd.gremlin-v2.0+json'
     }
   )
   
   client.open()
   

PHP

Získejte přístupový token se spravovanou identitou nebo instančním objektem pro získání primárního klíče služby Azure Cosmos DB pro Gremlin voláním rozhraní REST API na adrese AZURE_COSMOS_LISTKEYURL.

$endpoint = getenv('AZURE_COSMOS_RESOURCEENDPOINT');
$username = getenv('AZURE_COSMOS_USERNAME');
$port = getenv('AZURE_COSMOS_PORT');

$db = new Connection([
    'host' => $endpoint,
    'username' => $username,
    'password' => $password,
    'port' => $port,
    'ssl' => TRUE
]);

Další

V jiných jazycích můžete použít koncový bod Apache Gremlin a další vlastnosti, které Konektor služby nastaví na proměnné prostředí pro připojení k prostředku Azure Cosmos DB for Apache Gremlin. Podrobnosti o proměnné prostředí najdete v tématu Integrace služby Azure Cosmos DB pro Apache Gremlin s konektorem služby.

Connection string

Upozorňující

Microsoft doporučuje používat nejbezpečnější dostupný tok ověřování. Ověřovací tok popsaný v tomto postupu vyžaduje velmi vysoký stupeň důvěryhodnosti v aplikaci a nese rizika, která nejsou přítomna v jiných tocích. Tento tok byste měli použít jenom v případě, že jiné bezpečnější toky, jako jsou spravované identity, nejsou přijatelné.

Výchozí název proměnné prostředí	Popis	Příklad hodnoty
AZURE_COSMOS_HOSTNAME	Jedinečný identifikátor prostředku Gremlin (UFI)	<Azure-Cosmos-DB-account>.gremlin.cosmos.azure.com
AZURE_COSMOS_PORT	Port připojení	443
AZURE_COSMOS_USERNAME	Vaše uživatelské jméno	/dbs/<database>/colls/<collection or graphs>
AZURE_COSMOS_PASSWORD	Vaše heslo	<password>

Ukázkový kód

Informace o připojení ke službě Azure Cosmos DB pro Gremlin pomocí připojovací řetězec najdete v následujících krocích a kódu.

.NET

1. Nainstalujte závislost.

   dotnet add package Gremlin.Net
   

2. Získejte informace o připojení z proměnných prostředí přidaných konektorem služby a připojte se ke službě Azure Cosmos DB pro Apache Gremlin.

   using System;
   using Gremlin.Net.Driver;
   
   var gremlinEndpoint = Environment.GetEnvironmentVariable("AZURE_COSMOS_RESOURCEENDPOINT");
   var userName = Environment.GetEnvironmentVariable("AZURE_COSMOS_USERNAME");
   var password = Environment.GetEnvironmentVariable("AZURE_COSMOS_PASSWORD");
   var gremlinPort = Int32.Parse(Environment.GetEnvironmentVariable("AZURE_COSMOS_PORT"));
   
   var server = new GremlinServer(
       hostname: gremlinEndpoint,
       port: gremlinPort,
       username: userName,
       password: password,
       enableSsl: true
   );
   
   using var client = new GremlinClient(
       gremlinServer: server,
       messageSerializer: new Gremlin.Net.Structure.IO.GraphSON.GraphSON2MessageSerializer()
   );
   

Java

1. Do souboru pom.xml přidejte následující závislost:

   <dependency>
     <groupId>org.apache.tinkerpop</groupId>
     <artifactId>gremlin-driver</artifactId>
     <version>3.4.13</version>
   </dependency>
   

2. Získejte informace o připojení z proměnných prostředí přidaných konektorem služby a připojte se ke službě Azure Cosmos DB pro Apache Gremlin.

   import org.apache.tinkerpop.gremlin.driver.Client;
   import org.apache.tinkerpop.gremlin.driver.Cluster;
   import javax.net.ssl.*;
   import java.net.InetSocketAddress;
   
   int gremlinPort = Integer.parseInt(System.getenv("AZURE_COSMOS_PORT"));
   String username = System.getenv("AZURE_COSMOS_USERNAME");
   String gremlinEndpoint = System.getenv("AZURE_COSMOS_RESOURCEENDPOINT");
   String password = System.getenv("AZURE_COSMOS_PASSWORD");
   
   Cluster cluster;
   Client client;
   
   cluster = Cluster.addContactPoint​(gremlinEndpoint).port(gremlinPort).credentials(username, password).create();
   

Python

1. Nainstalujte závislost.

   pip install gremlinpython
   

2. Získejte informace o připojení z proměnných prostředí přidaných konektorem služby a připojte se ke službě Azure Cosmos DB pro Apache Gremlin.

   import os
   from gremlin_python.driver import client, serializer
   
   username = os.getenv('AZURE_COSMOS_USERNAME')
   password = os.getenv('AZURE_COSMOS_PASSWORD')
   endpoint = os.getenv('AZURE_COSMOS_RESOURCEENDPOINT')
   port = os.getenv('AZURE_COSMOS_PORT')
   
   client = client.Client(
       url=endpoint,
       traversal_source="g",
       username=username,
       password=password,
       message_serializer=serializer.GraphSONSerializersV2d0(),
   )
   

Přejít

1. Nainstalujte závislost.

   go get github.com/go-gremlin/gremlin
   

2. Získejte informace o připojení z proměnných prostředí přidaných konektorem služby a připojte se ke službě Azure Cosmos DB pro Apache Gremlin.

   username = os.Getenv("AZURE_COSMOS_USERNAME")
   password = os.getenv("AZURE_COSMOS_PASSWORD")
   endpoint = os.getenv("AZURE_COSMOS_RESOURCEENDPOINT")
   port = os.getenv("AZURE_COSMOS_PORT")
   
   auth := gremlin.OptAuthUserPass(username, password)
    client, err := gremlin.NewClient(endpoint, auth)
   

NodeJS

1. Nainstalujte závislost.

   npm install gremlin
   

2. Získejte informace o připojení z proměnných prostředí přidaných konektorem služby a připojte se ke službě Azure Cosmos DB pro Apache Gremlin.

   import gremlin from 'gremlin'
   
   const username = process.env.AZURE_COSMOS_USERNAME;
   const password = process.env.AZURE_COSMOS_PASSWORD;
   const endpoint = process.env.AZURE_COSMOS_RESOURCEENDPOINT;
   const port = process.env.AZURE_COSMOS_PORT;
   
   const credentials = new gremlin.driver.auth.PlainTextSaslAuthenticator(
      username,
      password
    )
   
   const client = new gremlin.driver.Client(
      endpoint,
      {
        credentials,
        traversalsource: 'g',
        rejectUnauthorized: true,
        mimeType: 'application/vnd.gremlin-v2.0+json'
      }
    )
   
    client.open()
   

PHP

Získejte informace o připojení z proměnných prostředí přidaných konektorem služby a připojte se ke službě Azure Cosmos DB pro Apache Gremlin.

$endpoint = getenv('AZURE_COSMOS_RESOURCEENDPOINT');
$username = getenv('AZURE_COSMOS_USERNAME');
$password = getenv('AZURE_COSMOS_PASSWORD');
$port = getenv('AZURE_COSMOS_PORT');

$db = new Connection([
    'host' => $endpoint,
    'username' => $username,
    'password' => $password,
    'port' => $port,
    'ssl' => TRUE
]);

Další

V jiných jazycích můžete použít koncový bod Apache Gremlin a další vlastnosti, které Konektor služby nastaví na proměnné prostředí pro připojení k prostředku Azure Cosmos DB for Apache Gremlin. Podrobnosti o proměnné prostředí najdete v tématu Integrace služby Azure Cosmos DB pro Apache Gremlin s konektorem služby.

Instanční objekt

Výchozí název proměnné prostředí	Popis	Příklad hodnoty
AZURE_COSMOS_LISTKEYURL	Adresa URL pro získání připojovací řetězec	https://management.azure.com/subscriptions/<subscription-ID>/resourceGroups/<resource-group-name>/providers/Microsoft.DocumentDB/databaseAccounts/<Azure-Cosmos-DB-account>/listKeys?api-version=2021-04-15
AZURE_COSMOS_SCOPE	Rozsah spravované identity	https://management.azure.com/.default
AZURE_COSMOS_RESOURCEENDPOINT	Váš koncový bod prostředku	https://<Azure-Cosmos-DB-account>.documents.azure.com:443/
AZURE_COSMOS_HOSTNAME	Jedinečný identifikátor prostředku Gremlin (UFI)	<Azure-Cosmos-DB-account>.gremlin.cosmos.azure.com
AZURE_COSMOS_PORT	Port připojení Gremlin	10350
AZURE_COSMOS_USERNAME	Vaše uživatelské jméno	</dbs/<database>/colls/<collection or graphs>
AZURE_COSMOS_CLIENTID	ID klienta	<client-ID>
AZURE_COSMOS_CLIENTSECRET	Tajný klíč klienta	<client-secret>
AZURE_COSMOS_TENANTID	ID vašeho tenanta	<tenant-ID>

Ukázkový kód

Informace o připojení ke službě Azure Cosmos DB pro Gremlin pomocí instančního objektu najdete v následujících krocích a kódu.

.NET

1. Nainstalujte závislosti.

   dotnet add package Gremlin.Net
   dotnet add package Azure.Identity
   

2. Získejte přístupový token pro spravovanou identitu nebo instanční objekt pomocí klientské knihovny Azure.Identity. Použijte přístupový token a AZURE_COSMOS_LISTKEYURL získejte heslo. Získejte informace o připojení z proměnných prostředí přidaných konektorem služby a připojte se ke službě Azure Cosmos DB pro Apache Gremlin. Při použití následujícího kódu odkomentujte část fragmentu kódu pro typ ověřování, který chcete použít.

   using System;
   using System.Security.Authentication;
   using System.Net.Security;
   using System.Net.Http;
   using System.Security.Authentication;
   using System.Threading.Tasks;
   using System;
   using Gremlin.Net.Driver;
   using Azure.Identity;
   
   var gremlinEndpoint = Environment.GetEnvironmentVariable("AZURE_COSMOS_RESOURCEENDPOINT");
   var userName = Environment.GetEnvironmentVariable("AZURE_COSMOS_USERNAME");
   var gremlinPort = Int32.Parse(Environment.GetEnvironmentVariable("AZURE_COSMOS_PORT"));
   var listKeyUrl = Environment.GetEnvironmentVariable("AZURE_COSMOS_LISTKEYURL");
   var scope = Environment.GetEnvironmentVariable("AZURE_COSMOS_SCOPE");
   
   // Uncomment the following lines corresponding to the authentication type you want to use.
   // For system-assigned identity.
   // var tokenProvider = new DefaultAzureCredential();
   
   // For user-assigned identity.
   // var tokenProvider = new DefaultAzureCredential(
   //     new DefaultAzureCredentialOptions
   //     {
   //         ManagedIdentityClientId = Environment.GetEnvironmentVariable("AZURE_COSMOS_CLIENTID");
   //     }
   // );
   
   // For service principal.
   // var tenantId = Environment.GetEnvironmentVariable("AZURE_COSMOS_TENANTID");
   // var clientId = Environment.GetEnvironmentVariable("AZURE_COSMOS_CLIENTID");
   // var clientSecret = Environment.GetEnvironmentVariable("AZURE_COSMOS_CLIENTSECRET");
   // var tokenProvider = new ClientSecretCredential(tenantId, clientId, clientSecret);
   
   // Acquire the access token. 
   AccessToken accessToken = await tokenProvider.GetTokenAsync(
       new TokenRequestContext(scopes: new string[]{ scope }));
   
   // Get the password.
   var httpClient = new HttpClient();
   httpClient.DefaultRequestHeaders.Add("Authorization", $"Bearer {accessToken.Token}");
   var response = await httpClient.POSTAsync(listKeyUrl);
   var responseBody = await response.Content.ReadAsStringAsync();
   var keys = JsonConvert.DeserializeObject<Dictionary<string, string>>(responseBody);
   var password = keys["primaryMasterKey"];
   
   // Connect to Azure Cosmos DB for Apache Gremlin
   var server = new GremlinServer(
       hostname: gremlinEndpoint,
       port: gremlinPort,
       username: userName,
       password: password,
       enableSsl: true
   );
   
   using var client = new GremlinClient(
       gremlinServer: server,
       messageSerializer: new Gremlin.Net.Structure.IO.GraphSON.GraphSON2MessageSerializer()
   );        
   
   

Java

1. Do souboru pom.xml přidejte následující závislosti:

   <dependency>
     <groupId>org.apache.tinkerpop</groupId>
     <artifactId>gremlin-driver</artifactId>
     <version>3.4.13</version>
   </dependency>
   <dependency>
       <groupId>com.azure</groupId>
       <artifactId>azure-identity</artifactId>
       <version>1.1.5</version>
   </dependency>
   

2. Získejte přístupový token pro spravovanou identitu nebo instanční objekt pomocí azure-identity. Použijte přístupový token a AZURE_COSMOS_LISTKEYURL získejte heslo. Získejte informace o připojení z proměnných prostředí přidaných konektorem služby a připojte se ke službě Azure Cosmos DB pro Apache Gremlin. Při použití následujícího kódu odkomentujte část fragmentu kódu pro typ ověřování, který chcete použít.

   import org.apache.tinkerpop.gremlin.driver.Client;
   import org.apache.tinkerpop.gremlin.driver.Cluster;
   import javax.net.ssl.*;
   import java.net.InetSocketAddress;
   import com.azure.identity.*;
   import com.azure.core.credential.*;
   import java.net.http.*;
   import java.net.URI;
   
   int gremlinPort = Integer.parseInt(System.getenv("AZURE_COSMOS_PORT"));
   String username = System.getenv("AZURE_COSMOS_USERNAME");
   String gremlinEndpoint = System.getenv("AZURE_COSMOS_RESOURCEENDPOINT");
   String listKeyUrl = System.getenv("AZURE_COSMOS_LISTKEYURL");
   String scope = System.getenv("AZURE_COSMOS_SCOPE");
   
   // Uncomment the following lines corresponding to the authentication type you want to use.
   // For system managed identity.
   // DefaultAzureCredential defaultCredential = new DefaultAzureCredentialBuilder().build();
   
   // For user assigned managed identity.
   // DefaultAzureCredential defaultCredential = new DefaultAzureCredentialBuilder()
   //     .managedIdentityClientId(System.getenv("AZURE_COSMOS_CLIENTID"))
   //     .build();
   
   // For service principal.
   // ClientSecretCredential defaultCredential = new ClientSecretCredentialBuilder()
   //   .clientId(System.getenv("AZURE_COSMOS_CLIENTID"))
   //   .clientSecret(System.getenv("AZURE_COSMOS_CLIENTSECRET"))
   //   .tenantId(System.getenv("AZURE_COSMOS_TENANTID"))
   //   .build();
   
   // Get the access token.
   AccessToken accessToken = defaultCredential.getToken(new TokenRequestContext().addScopes(new String[]{ scope })).block();
   String token = accessToken.getToken();
   
   // Get the password.
   HttpClient client = HttpClient.newBuilder().build();
   HttpRequest request = HttpRequest.newBuilder()
       .uri(new URI(listKeyUrl))
       .header("Authorization", "Bearer " + token)
       .POST()
       .build();
   HttpResponse<String> response = client.send(request, HttpResponse.BodyHandlers.ofString());
   JSONParser parser = new JSONParser();
   JSONObject responseBody = parser.parse(response.body());
   String gremlinPassword = responseBody.get("primaryMasterKey");
   
   // Connect to Azure Cosmos DB for Apache Gremlin
   Cluster cluster;
   Client client;
   
   cluster = Cluster.addContactPoint​(gremlinEndpoint).port(gremlinPort).credentials(username, password).create();
   

Python

1. Nainstalujte závislosti.

   pip install gremlinpython
   

2. Slouží azure-identity k ověření pomocí spravované identity nebo instančního objektu a odeslání požadavku na AZURE_COSMOS_LISTKEYURL získání hesla. Získejte informace o připojení z proměnných prostředí přidaných konektorem služby a připojte se ke službě Azure Cosmos DB pro Apache Gremlin. Při použití následujícího kódu odkomentujte část fragmentu kódu pro typ ověřování, který chcete použít.

   from gremlin_python.driver import client, serializer
   import requests
   from azure.identity import ManagedIdentityCredential, ClientSecretCredential
   
   username = os.getenv('AZURE_COSMOS_USERNAME')
   endpoint = os.getenv('AZURE_COSMOS_RESOURCEENDPOINT')
   port = os.getenv('AZURE_COSMOS_PORT')
   listKeyUrl = os.getenv('AZURE_COSMOS_LISTKEYURL')
   scope = os.getenv('AZURE_COSMOS_SCOPE')
   
   # Uncomment the following lines corresponding to the authentication type you want to use.
   # For system-assigned managed identity
   # cred = ManagedIdentityCredential()
   
   # For user-assigned managed identity
   # managed_identity_client_id = os.getenv('AZURE_COSMOS_CLIENTID')
   # cred = ManagedIdentityCredential(client_id=managed_identity_client_id)
   
   # For service principal
   # tenant_id = os.getenv('AZURE_COSMOS_TENANTID')
   # client_id = os.getenv('AZURE_COSMOS_CLIENTID')
   # client_secret = os.getenv('AZURE_COSMOS_CLIENTSECRET')
   # cred = ClientSecretCredential(tenant_id=tenant_id, client_id=client_id, client_secret=client_secret)
   
   # Get the password 
   session = requests.Session()
   token = cred.get_token(scope)
   response = session.post(listKeyUrl, headers={"Authorization": "Bearer {}".format(token.token)})
   keys_dict = response.json()
   password = keys_dict['primaryMasterKey']
   
   # Connect to Azure Cosmos DB for Apache Gremlin.
   client = client.Client(
       url=endpoint,
       traversal_source="g",
       username=username,
       password=password,
       message_serializer=serializer.GraphSONSerializersV2d0(),
   )
   

Přejít

1. Nainstalujte závislosti.

   go get github.com/Azure/azure-sdk-for-go/sdk/azidentity
   go get github.com/go-gremlin/gremlin
   

2. V kódu získejte přístupový token pomocí azidentitya pak ho použijte k získání hesla. Získejte informace o připojení z proměnné prostředí přidané konektorem služby a připojte se ke službě Azure Cosmos DB pro Apache Gremlin. Při použití následujícího kódu odkomentujte část fragmentu kódu pro typ ověřování, který chcete použít.

   import (
       "fmt"
       "os"
       "context"
       "log"
       "io/ioutil"
       "encoding/json"
   
       "github.com/go-gremlin/gremlin"
       "github.com/Azure/azure-sdk-for-go/sdk/azidentity"
   )
   
   func main() {
       username = os.Getenv("AZURE_COSMOS_USERNAME")
       endpoint = os.getenv("AZURE_COSMOS_RESOURCEENDPOINT")
       port = os.getenv("AZURE_COSMOS_PORT")
       listKeyUrl = os.Getenv("AZURE_COSMOS_LISTKEYURL")
       scope = os.Getenv("AZURE_COSMOS_SCOPE")
   
       // Uncomment the following lines corresponding to the authentication type you want to use.
       // For system-assigned identity.
       // cred, err := azidentity.NewDefaultAzureCredential(nil)
   
       // For user-assigned identity.
       // clientid := os.Getenv("AZURE_COSMOS_CLIENTID")
       // azidentity.ManagedIdentityCredentialOptions.ID := clientid
       // options := &azidentity.ManagedIdentityCredentialOptions{ID: clientid}
       // cred, err := azidentity.NewManagedIdentityCredential(options)
   
       // For service principal.
       // clientid := os.Getenv("AZURE_COSMOS_CLIENTID")
       // tenantid := os.Getenv("AZURE_COSMOS_TENANTID")
       // clientsecret := os.Getenv("AZURE_COSMOS_CLIENTSECRET")
       // cred, err := azidentity.NewClientSecretCredential(tenantid, clientid, clientsecret, &azidentity.ClientSecretCredentialOptions{})
   
       // Acquire the access token.
       ctx, cancel := context.WithTimeout(context.Background(), 30*time.Second)
       token, err := cred.GetToken(ctx, policy.TokenRequestOptions{
           Scopes: []string{scope},
       })
   
       // Acquire the connection string.
       client := &http.Client{}
       req, err := http.NewRequest("POST", listKeyUrl, nil)
       req.Header.Add("Authorization", "Bearer " + token.Token)
       resp, err := client.Do(req)
       body, err := ioutil.ReadAll(resp.Body)
       var result map[string]interface{}
       json.Unmarshal(body, &result)
       password, err := result["primaryMasterKey"];
   
       auth := gremlin.OptAuthUserPass(username, password)
        client, err := gremlin.NewClient(endpoint, auth)
   }
   

NodeJS

1. Nainstalujte závislosti.

   npm install gremlin
   npm install --save @azure/identity
   

2. V kódu získejte přístupový token pomocí @azure/identitya pak ho použijte k získání hesla. Získejte informace o připojení z proměnné prostředí přidané konektorem služby a připojte se ke službě Azure Cosmos DB pro Apache Gremlin. Při použití následujícího kódu odkomentujte část fragmentu kódu pro typ ověřování, který chcete použít.

   import { DefaultAzureCredential,ClientSecretCredential } from "@azure/identity";
   import gremlin from 'gremlin'
   const axios = require('axios');
   
   let username = process.env.AZURE_COSMOS_USERNAME;
   let endpoint = process.env.AZURE_COSMOS_RESOURCEENDPOINT;
   let port = process.env.AZURE_COSMOS_PORT;
   let listKeyUrl = process.env.AZURE_COSMOS_LISTKEYURL;
   let scope = process.env.AZURE_COSMOS_SCOPE;
   
   // Uncomment the following lines corresponding to the authentication type you want to use.  
   // For system-assigned identity.
   // const credential = new DefaultAzureCredential();
   
   // For user-assigned identity.
   // const clientId = process.env.AZURE_COSMOS_CLIENTID;
   // const credential = new DefaultAzureCredential({
   //     managedIdentityClientId: clientId
   // });
   
   // For service principal.
   // const tenantId = process.env.AZURE_COSMOS_TENANTID;
   // const clientId = process.env.AZURE_COSMOS_CLIENTID;
   // const clientSecret = process.env.AZURE_COSMOS_CLIENTSECRET;
   
   // Acquire the access token.
   var accessToken = await credential.getToken(scope);
   
   // Get the password.
   const config = {
       method: 'post',
       url: listKeyUrl,
       headers: { 
         'Authorization': `Bearer ${accessToken.token}`
       }
   };
   const response = await axios(config);
   const keysDict = response.data;
   const password = keysDict['primaryMasterKey'];
   
   const credentials = new gremlin.driver.auth.PlainTextSaslAuthenticator(
     username,
     password
   )
   
   const client = new gremlin.driver.Client(
     endpoint,
     {
       credentials,
       traversalsource: 'g',
       rejectUnauthorized: true,
       mimeType: 'application/vnd.gremlin-v2.0+json'
     }
   )
   
   client.open()
   

PHP

Získejte přístupový token se spravovanou identitou nebo instančním objektem pro získání primárního klíče služby Azure Cosmos DB pro Gremlin voláním rozhraní REST API na adrese AZURE_COSMOS_LISTKEYURL.

$endpoint = getenv('AZURE_COSMOS_RESOURCEENDPOINT');
$username = getenv('AZURE_COSMOS_USERNAME');
$port = getenv('AZURE_COSMOS_PORT');

$db = new Connection([
    'host' => $endpoint,
    'username' => $username,
    'password' => $password,
    'port' => $port,
    'ssl' => TRUE
]);

Další

V jiných jazycích můžete použít koncový bod Apache Gremlin a další vlastnosti, které Konektor služby nastaví na proměnné prostředí pro připojení k prostředku Azure Cosmos DB for Apache Gremlin. Podrobnosti o proměnné prostředí najdete v tématu Integrace služby Azure Cosmos DB pro Apache Gremlin s konektorem služby.

Další kroky

Další informace o konektoru Service Connector najdete v následujících kurzech.

Další informace o konceptech konektoru Service Connector