put_records () принимает только ключевые аргументы в Kinesis boto3 Python API

Отчет о применении для application_ (состояние: ПРИНЯТО) никогда не заканчивается для Spark Submit (с Spark 1.2.0 на YARN)

Какова задержка данных потокового журнала между облачными сервисами AWS и Google?

Кто-нибудь имел опыт работы с:Отправка потоковых / микропакетированных данных журнала из Amazon в BigQuery для обработки и может пролить свет на любую пробле...

Ожидаемое поведение для AWS Kinesis ShardIteratorType TRIM_HORIZON

контекстЯ не обязательно имею в виду приложение на основе KCL, просто вызовы чистого API Kinesis.Использует ли

@John Rotenstein Да, ссылка github, которую вы вставили, - это то, что я пытаюсь достичь, но в этой ссылке, чтобы достичь, я должен знать java, я знаю python, поэтому я решил использовать модуль python, awscli или boto. мой поток aws-connect --- отправка данных в ---> Kinesis -------> транскодер ----> текст ------> выбор необходим с помощью comprehend ----> вставка в база данных. Вызов клиента в реальном времени. Я хочу переписать, не офлайновая идея, это требование, которое необходимо выполнить вживую, поэтому использование Kinesis позволит сохранить звук на S3, а затем преобразовать с помощью транскодера.

ередать выходной аудиопоток видеопотока AWS Kinesis (KVS) в сервис AWS Transcribe и получить преобразование звука в текст в реальном времени? Я принял аудио через amazon connect to KVS (видеопоток Kinesis). Меня интересует, какой формат ...

Вызовите REST API для Amazon Kinesis с настройкой API Gateway

Я пытаюсь отправить HTTP-запрос на отправку записи в Amazon Kinesis Stream. Есть несколько способов (Kinesis Client, KPL, настройка AWS Gateway в качестве Ki...

Проблемы с надежностью Checkpointing / WAL в Spark Streaming 1.6.0

ОписаниеУ нас есть приложение Spark Streaming 1.5.2 в Scala, которое считывает события JSON из потока Kinesis, выполняет некоторые преобразования / агрегации...

Как разветвлять поток кинесиса AWS?

Я сделал это, вероятно, 5 разными способами для разных проектов, над которыми я работал с различными требованиями. Самый простой способ - смоделировать разрыв между производителем / потребителем (основываясь на показателях того, сколько элементов в очереди / насколько далеко отстает «текущий» в потоке), и отрегулировать поведение либо производителя, либо потребителя на основе значения этого показателя ( автоматически масштабировать потребителей, или производить другой тип или меньше предметов). Если вы можете описать поведение, вы можете смоделировать и кодировать его.

ичок в распределенной потоковой обработке (Spark). Я прочитал некоторые учебные пособия / примеры, в которых рассказывается о том, как обратное давление приводит к замедлению работы производителя (ов) в ответ на перегрузку потребителей. ...

несколько потребителей на осколок кинезиса

Я читал, у вас может быть несколько потребительских приложений для каждого потока кинезиса.http://docs.aws.amazon.com/kinesis/latest/dev/developing-consumers...