Intestazioni di risposta del server Azure Cosmos DB per Gremlin

SI APPLICA A: Gremlin

Questo articolo illustra le intestazioni restituite dal server Azure Cosmos DB per Gremlin al chiamante al momento dell'esecuzione della richiesta. Queste intestazioni sono utili per la risoluzione dei problemi relativi alle prestazioni delle richieste, creando un'applicazione che si integra in modo nativo con il servizio Azure Cosmos DB e semplificando il supporto tecnico.

Tenere presente che l'assunzione di dipendenze da queste intestazioni limita la portabilità dell'applicazione ad altre implementazioni Gremlin. In cambio, si sta ottenendo un'integrazione più stretta con Azure Cosmos DB per Gremlin. Queste intestazioni non sono uno standard TinkerPop.

Intestazioni

Codici di stato

Di seguito sono elencati i codici più comuni restituiti per x-ms-status-code l'attributo di stato dal server.

Esempi

Applicazione client di esempio basata su Gremlin.Net che legge un attributo di stato:

// 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.
}

Esempio che illustra come leggere l'attributo di stato dal client Java Gremlin:

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
    }
  }
}

Passaggi successivi

• Codici di stato HTTP per Azure Cosmos DB
• Intestazioni comuni della risposta REST di Azure Cosmos DB
• Requisiti del provider di driver Graph TinkerPop