Help Center/ Data Ingestion Service/ SDK Reference/ Getting Started with SDK/ Using the Python SDK/ Uploading Streaming Data in JSON Format
Updated on 2024-10-25 GMT+08:00
View PDF
Share

Uploading Streaming Data in JSON Format

Initialize a DIS SDK client instance as instructed in Initializing a DIS SDK Client Instance.

Configure the following parameter:

1
 
streamname ="dis-test1"  #Name of an existing stream.

records of the putRecords_test method in the putRecords_sample.py file is the data to be uploaded. The data is uploaded in the following format:

1
2
3
4
 
records=[{"data": "abcdefd", "partition_key": "1"}]
#data: data to be uploaded. The value is user-definable; partition_key: partition to which data is written. The value is user-definable. 
 record1 = {"data": "xxx","partition_key": partition_key}   
#You can write multiple pieces of data. The data format is shown in record1. Each time a piece of data is written, the append method is used to transfer the data to the records.

After configuring the parameters, run the putRecords_sample.py file to call putRecords_test. The following is an example response:

1
2
 
200
{'failed_record_count': 0, 'records': [{'partition_id': 'shardId-0000000001', 'sequence_number': '15'}]}
Parent topic: Using the Python SDK