推进流

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

所需权限：使用流、查看标签。

• 重击

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

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

• 响应

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

每个提取请求都会返回一个sequence_id ，表示提取请求到目前为止的位置。 将该相同的sequence_id传递到高级 api 将确保下次对流执行提取时，会从此位置开始。 您可以使用当前批次的sequence_id进入下一批。 或者，您可以使用当前注释的sequence_id前进到下一条注释。

由于应用程序可以成功处理注释，但在高级步骤中失败，因此在客户端应用程序端处理多次查看同一条注释非常重要。

名称	类型	必填	说明
sequence_id	字符串	是	要将流推进到的序列 ID。