Guide de l’utilisateur de Communications Mining

Dernière mise à jour 20 oct. 2025

Réinitialiser un flux

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

Autorisations requises : utiliser des flux, afficher les libellés,

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

Nœud

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

Réponse

{
  "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"
  }
}

Un flux peut être réinitialisé pour déplacer sa position vers l'arrière ou vers l'avant dans le temps, soit pour répéter les commentaires précédemment renvoyés, soit pour ignorer des commentaires. L'horodatage utilisé pour réinitialiser un flux fait référence à l'heure à laquelle les commentaires ont été téléchargés (c'est-à-dire la propriété created_at du commentaire, plutôt que sa propriété timestamp ).