Protobuf格式上传流式数据
参见初始化DIS客户端的操作初始化一个DIS客户端实例。
初始化DIS客户端,加入一项参数bodySerializeType,如下所示:
cli = disclient(endpoint='', ak='', sk='', projectid='', region='',bodySerializeType='protobuf')
配置参数如下:
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'}]}
|
