Bringen Sie einen Stream vor

/api/v1/datasets/<project>/<dataset_name>/streams/<stream_name>/advance

Erforderliche Berechtigungen: Streams verbrauchen, Beschriftungen anzeigen.

• Bash

  curl -X POST 'https://<my_api_endpoint>/api/v1/datasets/project1/collateral/streams/dispute/advance' \
      -H "Authorization: Bearer $REINFER_TOKEN" \
      -H "Content-Type: application/json" \
      -d '{
    "sequence_id": "qs8QcHIBAADJ1p3W2FtmBB3QiOJsCJlR"
  }'

• Knoten

  const request = require("request");
  
  request.post(
    {
      url: "https://<my_api_endpoint>/api/v1/datasets/project1/collateral/streams/dispute/advance",
      headers: {
        Authorization: "Bearer " + process.env.REINFER_TOKEN,
      },
      json: true,
      body: { sequence_id: "qs8QcHIBAADJ1p3W2FtmBB3QiOJsCJlR" },
    },
    function (error, response, json) {
      // digest response
      console.log(JSON.stringify(json, null, 2));
    }
  );

• Python

  import json
  import os
  
  import requests
  
  response = requests.post(
      "https://<my_api_endpoint>/api/v1/datasets/project1/collateral/streams/dispute/advance",
      headers={"Authorization": "Bearer " + os.environ["REINFER_TOKEN"]},
      json={"sequence_id": "qs8QcHIBAADJ1p3W2FtmBB3QiOJsCJlR"},
  )
  
  print(json.dumps(response.json(), indent=2, sort_keys=True))

• Antwort

  {
    "sequence_id": "qs8QcHIBAADJ1p3W2FtmBB3QiOJsCJlR",
    "status": "ok"
  }

Jede Abrufanforderung gibt ein sequence_id zurück, das die Position darstellt, an der sie abgerufen wurde. Wenn Sie den gleichen sequence_id an die Vorab-API übergeben, wird sichergestellt, dass der Stream beim nächsten Abruf an dieser Position gestartet wird. Sie können zum nächsten Batch vorgehen, indem Sie die sequence_id des aktuellen Batches verwenden. Alternativ können Sie mit dem sequence_id des aktuellen Kommentars zum nächsten Kommentar übergehen.

Da eine Anwendung einen Kommentar erfolgreich verarbeiten kann, aber im erweiterten Schritt fehlschlagen kann, ist es wichtig, dass ein Kommentar auf der Clientanwendungsseite mehrmals angezeigt wird.

Name	Typ	Erforderlich	BESCHREIBUNG
sequence_id	string	ja	Die Sequence-ID, zu der der Stream weitergeleitet werden soll.