文档首页 > > SDK参考> 使用SDK> 使用SDK(Python)> Protobuf格式上传流式数据

Protobuf格式上传流式数据

分享
更新时间: 2019/11/22 GMT+08:00

参见初始化DIS客户端的操作初始化一个DIS客户端实例。

初始化DIS客户端,加入一项参数bodySerializeType,如下所示:

cli = disclient(endpoint='', ak='', sk='', projectid='', region='',bodySerializeType='protobuf')

代码样例参考“protobuf_putRecords_sample.py”文件,配置参数如下:

1
streamname="dis-test1" #已存在的通道名

参照该文件中的test方法,bodySerializeType="protobuf"选取protobuf格式上传。

protobuf_putRecords_sample.py文件中的protobuf_putRecords_test方法中的records为需要上传的数据内容,数据上传格式如下:

1
2
3
4
records=[{"data": "abcdefd", "partition_key": 1}]
#"data":"xxx"为上传的数据值,请自定义;“partition_key”:“1”为数据写入的分区值,请自定义。
 record1 = {"data": "xxx","partition_key": partition_key}   
#可写入多条数据,数据格式如record1所示,每写一条数据使用下面的append方法传入records中。

配置好以上参数后,执行protobuf_putRecords_sample.py文件调用protobuf_putRecords_test方法,响应结果下:

1
2
200
{'failed_record_count': 0, 'records': [{'partition_id': 'shardId-0000000001', 'sequence_number': '15'}]}
分享:

    相关文档

    相关产品

文档是否有解决您的问题?

提交成功!

非常感谢您的反馈,我们会继续努力做到更好!

反馈提交失败,请稍后再试!

*必选

请至少选择或填写一项反馈信息

字符长度不能超过200

提交反馈 取消

如您有其它疑问,您也可以通过华为云社区问答频道来与我们联系探讨

跳转到云社区