Nagłówki odpowiedzi serwera Gremlin w usłudze Azure Cosmos DB

DOTYCZY: Gremlin

W tym artykule opisano nagłówki, które serwer usługi Azure Cosmos DB dla języka Gremlin powraca do elementu wywołującego po wykonaniu żądania. Te nagłówki są przydatne do rozwiązywania problemów z wydajnością żądań, tworzenia aplikacji, która integruje się natywnie z usługą Azure Cosmos DB i upraszcza obsługę klienta.

Należy pamiętać, że zależność od tych nagłówków ogranicza przenośność aplikacji do innych implementacji języka Gremlin. W zamian zyskujesz ściślejszą integrację z usługą Azure Cosmos DB dla języka Gremlin. Te nagłówki nie są standardem TinkerPop.

Nagłówki

Kody stanu

Poniżej wymieniono najczęściej kody zwracane dla x-ms-status-code atrybutu stanu przez serwer.

Przykłady

Przykładowa aplikacja kliencka oparta na Gremlin.Net, która odczytuje jeden atrybut stanu:

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

Przykład przedstawiający sposób odczytywania atrybutu stanu z klienta Języka Java języka 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
    }
  }
}

Następne kroki

• Kody stanu HTTP dla usługi Azure Cosmos DB
• Typowe nagłówki odpowiedzi REST usługi Azure Cosmos DB
• Wymagania dotyczące dostawcy sterowników programu TinkerPop Graph