Azure Cosmos DB a Gremlin-kiszolgáló válaszfejléceihez

A KÖVETKEZŐKRE VONATKOZIK: Gremlin

Ez a cikk azokat a fejléceket ismerteti, amelyeket az Azure Cosmos DB for Gremlin-kiszolgáló kérés végrehajtásakor visszatér a hívóhoz. Ezek a fejlécek hasznosak a kérések teljesítményének hibaelhárításához, az Azure Cosmos DB szolgáltatással natív módon integrálható alkalmazás létrehozásához és az ügyfelek támogatásának egyszerűsítéséhez.

Ne feledje, hogy a fejlécek függőségének figyelembe vételével az alkalmazás hordozhatóságát más Gremlin-implementációkra korlátozza. Cserébe szorosabb integrációt fog elérni a Gremlinhez készült Azure Cosmos DB-vel. Ezek a fejlécek nem TinkerPop szabványnak számítanak.

Fejlécek

Állapotkódok

A kiszolgáló által az állapotattribútumhoz x-ms-status-code visszaadott leggyakoribb kódok az alábbiakban találhatók.

Példák

Egy Gremlin.Net alapuló mintaügyfél-alkalmazás, amely egy állapotattribútumot olvas be:

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

Példa a Gremlin Java-ügyfél állapotattribútumának olvasására:

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

Következő lépések

• HTTP-állapotkódok az Azure Cosmos DB-hez
• Gyakori Azure Cosmos DB REST-válaszfejlécek
• A TinkerPop Graph illesztőprogram-szolgáltatói követelményei