Удаление потока данных в AWS SDK

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

• Имя удаляемого потока данных, например example-stream.
• Идентификатор облака, в котором будет удален поток, например b1gi1kuj2dht********.
• Идентификатор базы данных YDB с потоком, например cc8028jgtuab********.

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

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

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

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

2. Запустите программу:

   python3 stream_delete.py
   

   Результат:

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