Creating a stream in the AWS SDK

Use the create_stream method to create a stream. When you invoke this method, you should specify the following parameters:

• Name of a stream being created, e.g., example-stream.
• ID of a cloud to host the stream, e.g., b1gi1kuj2dht********.
• ID of an existing serverless YDB database, e.g., cc8028jgtuab********. For information about how to create a database, see the YDB documentation.
• Number of shards, e.g., 1.

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

To create a stream with the parameters specified above:

1. Create a file named stream_create.py and copy the following code into it:

   import boto3
   from pprint import pprint
   
   def create_stream(cloud, database, stream_name, shard_count):
       client = boto3.client('kinesis', endpoint_url="https://yds.serverless.yandexcloud.net")
       response = client.create_stream(
         StreamName="/ru-central1/{cloud}/{database}/{stream}".format(cloud=cloud,
                                                                       database=database,
                                                                       stream=stream_name),
         ShardCount=shard_count
       )
       return response
   
   if __name__ == '__main__':
     create_stream_response = create_stream(
       cloud="b1gi1kuj2dht********",
       database="cc8028jgtuab********",
       stream_name="example-stream",
       shard_count=1)
     print("The stream has been created successfully")
     pprint(create_stream_response)
   

2. Run the program:

   python3 stream_create.py
   

   Result:

   The stream has been created successfully
   {
     'ResponseMetadata': {
       'HTTPHeaders': {
         'connection': 'keep-alive',
         'content-length': '3',
         'content-type': 'application/json',
         'date': ''
         'GMT',
         'server': 'nginx/1.19.5',
         'HTTPStatusCode': 200,
         'RetryAttempts': 0
       }
     }
   }