Avanzar una transmisión

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

Permisos necesarios: Consumir transmisiones, Ver etiquetas.

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

• Nodo

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

• Respuesta

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

Cada solicitud de recuperación devuelve un sequence_id , que representa la posición a la que se ha recuperado. Al pasar ese mismo sequence_id a la API avanzada se asegurará de que la próxima vez que se realice una búsqueda en la transmisión, se iniciará desde esta posición. Puedes avanzar al siguiente lote utilizando el sequence_id del lote actual. Como alternativa, puedes avanzar al siguiente comentario utilizando el sequence_id del comentario actual.

Dado que una aplicación puede procesar correctamente un comentario pero fallar en el paso de avance, es importante gestionar un comentario que aparece varias veces en el lado de la aplicación cliente.

Nombre	Tipo	Obligatorio	Descripción
sequence_id	String	Sí	El ID de secuencia al que avanzar la transmisión.