Avancer un flux

Référence de l'API pour le point de terminaison avancé du flux, y compris les autorisations requises et les exemples de requêtes curl.

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

Autorisations requises : Utiliser des flux, Afficher des libellés.

• 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"
  }'
  

• Nœud

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

• Réponse

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

Each fetch request returns a sequence_id, which represents the position it has fetched up to. Passing that same sequence_id to the advance api will make sure that next time a fetch is performed on the stream, it will start from this position. You can advance to the next batch by using the current batch's sequence_id. Alternatively, you can advance to the next comment by using the current comment's sequence_id.

Étant donné qu'une application peut traiter un commentaire avec succès mais échouer à l'étape de progression, il est important de gérer un commentaire qui apparaît plusieurs fois du côté de l'application cliente.

Nom	Saisie de texte	Requis	DESCRIPTION
sequence_id	string	oui	L'ID de séquence vers lequel faire avancer le flux.