Communications Mining-Entwicklerhandbuch

Letzte Aktualisierung 26. Nov. 2024

Einen Stream zurücksetzen

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

Erforderliche Berechtigungen: Streams verbrauchen, Beschriftungen anzeigen.

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

Knoten

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

Antwort

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

Ein Stream kann zurückgesetzt werden, um seine Position im Zeitverlauf vorwärts oder rückwärts zu verschieben, um entweder zuvor zurückgegebene Kommentare zu wiederholen oder Kommentare zu überspringen. Der Zeitstempel, der zum Zurücksetzen eines Streams verwendet wird, bezieht sich auf die Zeit, zu der die Kommentare hochgeladen wurden (d. h. die Eigenschaft created_at des Kommentars und nicht die Eigenschaft timestamp ).