Antwoordheaders van Azure Cosmos DB voor Gremlin-server

VAN TOEPASSING OP: Gremlin

In dit artikel worden headers behandeld die azure Cosmos DB voor Gremlin-server retourneert naar de aanroeper bij het uitvoeren van de aanvraag. Deze headers zijn handig voor het oplossen van problemen met de prestaties van aanvragen, het bouwen van een toepassing die systeemeigen is geïntegreerd met de Azure Cosmos DB-service en het vereenvoudigen van de klantondersteuning.

Houd er rekening mee dat u de afhankelijkheid van deze headers beperkt tot andere Gremlin-implementaties. Als resultaat krijgt u een strakkere integratie met Azure Cosmos DB voor Gremlin. Deze headers zijn geen TinkerPop-standaard.

Kopteksten

Statuscodes

De meest voorkomende codes die door de server worden geretourneerd voor x-ms-status-code het statuskenmerk, worden hieronder vermeld.

Voorbeelden

Een voorbeeldclienttoepassing op basis van Gremlin.Net die één statuskenmerk leest:

// Following example reads a status code and total request charge from server response attributes.
// Variable "server" is assumed to be assigned to an instance of a GremlinServer that is connected to Azure Cosmos DB account.
using (GremlinClient client = new GremlinClient(server, new GraphSON2Reader(), new GraphSON2Writer(), GremlinClient.GraphSON2MimeType))
{
  ResultSet<dynamic> responseResultSet = await GremlinClientExtensions.SubmitAsync<dynamic>(client, requestScript: "g.V().count()");
  long statusCode = (long)responseResultSet.StatusAttributes["x-ms-status-code"];
  double totalRequestCharge = (double)responseResultSet.StatusAttributes["x-ms-total-request-charge"];

  // Status code and request charge are logged into application telemetry.
}

Een voorbeeld dat laat zien hoe u het statuskenmerk leest van de Gremlin Java-client:

try {
  ResultSet resultSet = this.client.submit("g.addV().property('id', '13')");
  List<Result> results = resultSet.all().get();

  // Process and consume results

} catch (ResponseException re) {
  // Check for known errors that need to be retried or skipped
  if (re.getStatusAttributes().isPresent()) {
    Map<String, Object> attributes = re.getStatusAttributes().get();
    int statusCode = (int) attributes.getOrDefault("x-ms-status-code", -1);

    // Now we can check for specific conditions
    if (statusCode == 409) {
        // Handle conflicting writes
      }
    }

    // Check if we need to delay retry
    if (attributes.containsKey("x-ms-retry-after-ms")) {
      // Read the value of the attribute as is
      String retryAfterTimeSpan = (String) attributes.get("x-ms-retry-after-ms"));

      // Convert the value into actionable duration
			LocalTime locaTime = LocalTime.parse(retryAfterTimeSpan);
			Duration duration = Duration.between(LocalTime.MIN, locaTime);

      // Perform a retry after "duration" interval of time has elapsed
    }
  }
}

Volgende stappen

• HTTP-statuscodes voor Azure Cosmos DB
• Algemene Azure Cosmos DB REST-antwoordheaders
• Vereisten voor TinkerPop Graph Driver Provider