Отправка данных в поток

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

• Имя потока данных, например example-stream.
• Идентификатор каталога, в котором находится поток, например aoeu1kuj2dhtaupdb5es.
• Идентификатор базы данных Yandex Managed Service for YDB с потоком, например cc8028jgtuabcqutgtbv.
• Отправляемые данные, например message.

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

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

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

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

   python3 stream_put_record.py
   

   Результат выполнения:

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