数据接入服务 DIS
数据接入服务 DIS
- 最新动态
- 产品介绍
- 快速入门
- 用户指南
- 最佳实践
- API参考
- SDK参考
- 常见问题
- 文档下载
- 通用参考
本文导读
展开导读
链接复制成功!
获取数据游标
参见初始化DIS客户端的操作初始化一个DIS客户端实例。
配置参数如下:
partitionId="shardId-0000000000" streamname=”dis-test1“ #已存在的通道名 5种游标设置使用参考如下: # startSeq与AT_SEQUENCE_NUMBER/AFTER_SEQUENCE_NUMBER搭配使用 r = cli.getCursor(streamname, partitionId, cursorType='AT_SEQUENCE_NUMBER', startSeq="0") # r = cli.getCursor(streamname, partitionId, cursorType='AFTER_SEQUENCE_NUMBER', startSeq="0") # timestamp与AT_TIMESTAMP搭配使用 # r = cli.getCursor(streamname, partitionId, cursorType='AT_TIMESTAMP',timestamp=1554694135190) # r = cli.getCursor(streamname, partitionId, cursorType='TRIM_HORIZON') # r = cli.getCursor(streamname, partitionId, cursorType='LATEST')
配置好以上参数,执行getCursor_sample.py文件调用getCursor_test方法,响应结果示例如下:
1 2 |
200 {"partition_cursor": "eyJnZXRJdGVyYXRvclBhcmFtIjp7InN0cmVhbS1uYW1lIjoiSCIsInBhcnRpdGlvbi1pZCI6InNoYXJkSWQtMDAwMDAwMDAwMCIsImN1cnNvci10eXBlIjoiQVRfU0VRVUVOQ0VfTlVNQkVSIiwic3RhcnRpbmctc2VxdWVuY2UtbnVtYmVyIjoiMCJ9LCJnZW5lcmF0ZVRpbWVzdGFtcCI6MTUzMjQyNDg4NzE1NH0"} |
父主题: 使用SDK(Python)