Submitting Checkpoints¶
Function¶
This API is used to submit checkpoints.
Calling Method¶
For details, see Calling APIs.
URI¶
POST /v2/{project_id}/checkpoints
Parameter | Mandatory | Type | Description |
|---|---|---|---|
project_id | Yes | String | Project ID |
Request Parameters¶
Parameter | Mandatory | Type | Description |
|---|---|---|---|
X-Auth-Token | Yes | String | User token It can be obtained by calling the IAM API used to obtain a user token. The value of X-Subject-Token in the response header is the user token. |
Parameter | Mandatory | Type | Description |
|---|---|---|---|
app_name | Yes | String | Name of the app, which is the unique identifier of a user data consumption program. |
checkpoint_type | Yes | String | Type of the checkpoint.
Enumeration values:
|
stream_name | Yes | String | Name of the stream |
partition_id | Yes | String | Partition identifier of the stream.Two partition ID formats are available:- shardId-0000000000- 0For example, if a stream has three partitions, the partition IDs are 0, 1, and 2, or shardId-0000000000, shardId-0000000001, and shardId-0000000002. |
sequence_number | Yes | String | Sequence number to be submitted, which is used to record the consumption checkpoint of the stream. Ensure that the sequence number is within the valid range. |
metadata | No | String | Metadata information of the consumer application. The metadata information can contain a maximum of 1,000 characters. Maximum: 1000 |
Response Parameters¶
None
Example Requests¶
Submitting Checkpoints
POST https://{Endpoint}/v2/{project_id}/checkpoints
{
"stream_name" : "newstream",
"app_name" : "newapp",
"partition_id" : "0",
"sequence_number" : "2",
"checkpoint_type" : "LAST_READ"
}
Example Responses¶
None
Status Codes¶
Status Code | Description |
|---|---|
201 | Normal response |
Error Codes¶
See Error Codes.