Guía para desarrolladores de Communications Mining

Última actualización 20 de dic. de 2024

Restablecer una transmisión

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

Permisos necesarios: Consumir transmisiones, Ver etiquetas.

Bash

curl -X POST 'https://<my_api_endpoint>/api/v1/datasets/project1/collateral/streams/dispute/reset' \
    -H "Authorization: Bearer $REINFER_TOKEN" \
    -H "Content-Type: application/json" \
    -d '{
  "to_comment_created_at": "2020-06-03T16:05:00"
}'curl -X POST 'https://<my_api_endpoint>/api/v1/datasets/project1/collateral/streams/dispute/reset' \
    -H "Authorization: Bearer $REINFER_TOKEN" \
    -H "Content-Type: application/json" \
    -d '{
  "to_comment_created_at": "2020-06-03T16:05:00"
}'

Nodo

const request = require("request");

request.post(
  {
    url: "https://<my_api_endpoint>/api/v1/datasets/project1/collateral/streams/dispute/reset",
    headers: {
      Authorization: "Bearer " + process.env.REINFER_TOKEN,
    },
    json: true,
    body: { to_comment_created_at: "2020-06-03T16:05:00" },
  },
  function (error, response, json) {
    // digest response
    console.log(JSON.stringify(json, null, 2));
  }
);const request = require("request");

request.post(
  {
    url: "https://<my_api_endpoint>/api/v1/datasets/project1/collateral/streams/dispute/reset",
    headers: {
      Authorization: "Bearer " + process.env.REINFER_TOKEN,
    },
    json: true,
    body: { to_comment_created_at: "2020-06-03T16:05:00" },
  },
  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/reset",
    headers={"Authorization": "Bearer " + os.environ["REINFER_TOKEN"]},
    json={"to_comment_created_at": "2020-06-03T16:05:00"},
)

print(json.dumps(response.json(), indent=2, sort_keys=True))import json
import os

import requests

response = requests.post(
    "https://<my_api_endpoint>/api/v1/datasets/project1/collateral/streams/dispute/reset",
    headers={"Authorization": "Bearer " + os.environ["REINFER_TOKEN"]},
    json={"to_comment_created_at": "2020-06-03T16:05:00"},
)

print(json.dumps(response.json(), indent=2, sort_keys=True))

Respuesta

{
  "sequence_id": "4LvtenIBAAA=",
  "status": "ok",
  "stream": {
    "created_at": "2019-08-03T12:30:00.123456Z",
    "dataset_id": "abcdef0123456789",
    "description": "Used by ACME RPA to create tickets for disputes.",
    "id": "0123456789abcdef",
    "model": {
      "version": 8
    },
    "name": "dispute",
    "title": "Collateral Disputes",
    "updated_at": "2019-08-03T12:30:00.123456Z"
  }
}{
  "sequence_id": "4LvtenIBAAA=",
  "status": "ok",
  "stream": {
    "created_at": "2019-08-03T12:30:00.123456Z",
    "dataset_id": "abcdef0123456789",
    "description": "Used by ACME RPA to create tickets for disputes.",
    "id": "0123456789abcdef",
    "model": {
      "version": 8
    },
    "name": "dispute",
    "title": "Collateral Disputes",
    "updated_at": "2019-08-03T12:30:00.123456Z"
  }
}

Una secuencia puede restablecerse para mover su posición hacia atrás o hacia adelante en el tiempo, ya sea para repetir los comentarios devueltos anteriormente o para omitir los comentarios. La marca de tiempo utilizada para restablecer una transmisión se refiere a la hora en que se cargaron los comentarios (es decir, la propiedad created_at del comentario, en lugar de su propiedad timestamp ).