Я пытаюсь создать поток Kinesis Firehose (на AWS), который записывается в корзину S3 с ограниченной политикой корзины. My bucket policy : { "Version": "2012-10-17", "Id": "S3PolicyId1", "Statement": [ { "Sid":...

Мы используем Kinesis Firehose для загрузки данных в несколько таблиц Redshift. Есть мониторы, чтобы увидеть успешные поставки. Однако нет монитора для проверки наличия ошибок в доставке - тех, которые записываются в таблицу stl_load_errors. У...

Я пытаюсь настроить лямбда-преобразования с помощью потока доставки Firehose. У меня есть роль IAM, определенная для Firehose, которая включает следующий документ политики: { "Statement": { "Action": [...

Я пытаюсь проверить концепцию таблицы лидеров в реальном времени, используя аналитику kinesis, и пытаюсь использовать их пример для начала работы, пример временного периода с потоком данных демонстрационного биржевого тикера. Однако я получаю...

Если я использую Kinesis Firehose, который записывает, скажем, S3, в качестве источника для Data Analytics, можно ли будет сохранить исходные данные из потока, как если бы после Firehose не было интегрированного Data Analytics? Или исходные данные,...

Мне нужно создать сценарий CDK для развертывания конвейера данных. Я уже создал лямбда-функцию, тему SNS, корзину S3 (очень легко), но мне сложно создать поток доставки Kinesis Firehose для помещения файлов в корзину S3. Мой код stack.py для потока...