Querying a Checkpoint
Initialize a DIS SDK client instance as instructed in Initializing a DIS SDK Client Instance.
The getCheckpoint_sample.py file provides a code sample. Configure the following parameters in this file:
1 2 3 |
streamname=" " #Name of the stream.
appName="xx" #Name of an existing application.
partitionId="shardId-0000000000" #Unique identifier of the partition.
|
Before obtaining the partition ID, import the stream name and then refer to the instructions in Querying Stream Details.
After configuring the parameters, run the getCheckpoint_sample.py file to call getCheckpoint_test. The following is an example response:
1 2 3 4 |
{
"sequence_number": "10",
"metadata": "metadata"
}
|
Last Article: Adding a Checkpoint
Next Article: Changing Partition Quantity
Did this article solve your problem?
Thank you for your score!Your feedback would help us improve the website.