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. Alternativamente, 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 avanzado, es importante manejar la visualización de un comentario 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.