# Protobuf格式上传流式数据
参见[初始化DIS客户端](https://support.huaweicloud.com/sdkreference-dis/dis_06_0043.html)的操作初始化一个DIS客户端实例。
初始化DIS客户端，加入一项参数bodySerializeType，如下所示：
```
cli = disclient(endpoint='', ak=os.environ.get("HUAWEICLOUD_SDK_AK"), sk=os.environ.get("HUAWEICLOUD_SDK_SK"), projectid='', region='',bodySerializeType='protobuf')
```
配置参数如下：
```
streamname="dis-test1" #已存在的通道名
```
参照该文件中的test方法，bodySerializeType="protobuf"选取protobuf格式上传。
protobuf_putRecords_sample.py文件中的protobuf_putRecords_test方法中的records为需要上传的数据内容，数据上传格式如下：
```
records=[{"data": "abcdefd", "partition_id": “shardId-0000000001”}]
#"data"："xxx"为上传的数据值，请自定义；“partition_id”:“shardId-0000000001”为数据写入的分区id值，请自定义。
 record1 = {"data": "xxx","partition_id": partition_id}   
#可写入多条数据，数据格式如record1所示，每写一条数据使用下面的append方法传入records中。
```
配置好以上参数后，执行protobuf_putRecords_sample.py文件调用protobuf_putRecords_test方法，响应结果下：
```
200
{'failed_record_count': 0, 'records': [{'partition_id': 'shardId-0000000001', 'sequence_number': '15'}]}
```