Sending data to a stream in the AWS SDK

To send data to a stream, use the put_record/put_records method. When you invoke this method, specify the following parameters:

• Stream name., e.g., example-stream.
• ID of the cloud the stream is located in, e.g., b1gi1kuj2dht********.
• ID of the YDB database containing the stream, e.g., cc8028jgtuab********.
• Data being sent, e.g., message.

You also need to configure the AWS SDK and assign the service account the yds.writer role.

To send data to the stream with the above parameters:

1. Create the stream_put_record.py file and paste the following code to it:

   import boto3
   from pprint import pprint
   
   def put_record(cloud, database, stream_name, message):
      client = boto3.client('kinesis', endpoint_url="https://yds.serverless.yandexcloud.net")
      response = client.put_record(
        StreamName="/ru-central1/{cloud}/{database}/{stream}".format(cloud=cloud,
                                                                     database=database,
                                                                     stream=stream_name),
       Data=message,
       PartitionKey=message
     )
     return response
   
   if __name__ == '__main__':
     put_record_response = put_record(
       cloud="b1gi1kuj2dht********",
       database="cc8028jgtuab********",
       stream_name="example-stream",
       message="message")
   
     print("The record has been sent successfully")
     pprint(put_record_response)
   

2. Run the program:

   python3 stream_put_record.py
   

   Result:

   The record has been sent successfully
   {
     'EncryptionType': 'NONE',
     'ResponseMetadata': {
       'HTTPHeaders': {
         'connection': 'keep-alive',
         'content-length': '81',
         'content-type': 'application/json',
         'date': ''
         'GMT',
         'server': 'nginx/1.19.5'
       },
       'HTTPStatusCode': 200,
       'RetryAttempts': 0
     },
     'SequenceNumber': '0',
     'ShardId': 'shard-000000'
   }