ストリームを前進させます。

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

必要なアクセス許可: ストリームの使用、ラベルの表示。

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

ノード

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

レスポンス

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

各フェッチ要求は、フェッチした位置を表す sequence_id を返します。同じ sequence_id を advance API に渡すと、次にストリームでフェッチが実行されたときに、この位置から開始されます。現在のバッチの sequence_idを使用して次のバッチに進むことができます。または、現在のコメントの sequence_idを使用して次のコメントに進むこともできます。

アプリケーションは、コメントを正常に処理できるのに前進の手順で失敗することがあります。そのため、クライアントアプリケーション側でコメントが複数回表示される状況を処理できるようにすることが重要です。