Создание потока данных в AWS SDK

Для создания потока данных используется метод create_stream. При вызове этого метода необходимо указать следующие параметры:

• Имя создаваемого потока данных, например example-stream.
• Идентификатор облака, в котором будет создан поток, например b1gi1kuj2dht********.
• Идентификатор существующей бессерверной базы данных YDB, например cc8028jgtuab********. Как создать новую базу данных, читайте в документации YDB.
• Число сегментов, например 1.

Вам также потребуется настроить AWS SDK и назначить сервисному аккаунту роль yds.editor.

Чтобы создать поток с параметрами, указанными выше:

1. Создайте файл stream_create.py и скопируйте в него следующий код:

   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. Запустите программу:

   python3 stream_create.py
   

   Результат:

   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
       }
     }
   }