数据接入服务 DIS
数据接入服务 DIS
- 最新动态
- 产品介绍
- 快速入门
- 用户指南
- 最佳实践
- API参考
- SDK参考
- 常见问题
- 文档下载
- 通用参考
本文导读
展开导读
链接复制成功!
Json格式上传流式数据
参见初始化DIS客户端的操作初始化一个DIS客户端实例。
配置参数如下:
1 |
streamname="dis-test1"| #已存在的通道名 |
putRecords_sample.py文件中的putRecords_test方法中的records为需要上传的数据内容,数据上传格式如下:
1 2 3 4 |
records=[{"data": "abcdefd", "partition_id": “shardId-0000000001”}] #"data":"xxx"为上传的数据值,请自定义;“partition_id”:“shardId-0000000001”为数据写入的分区id值,请自定义。 record1 = {"data": "xxx","partition_id": partition_id} #可写入多条数据,数据格式如record1所示,每写一条数据使用下面的append方法传入records中。 |
配置好以上参数后,执行putRecords_sample.py文件调用putRecords_test方法,响应结果如下:
1 2 |
200 {'failed_record_count': 0, 'records': [{'partition_id': 'shardId-0000000001', 'sequence_number': '15'}]} |
父主题: 使用SDK(Python)