Querying a Checkpoint

Initialize a DIS SDK client instance as instructed in Initializing a DIS SDK Client Instance.

Configure the following parameters\:

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