[ aws . kinesisanalyticsv2 ]
восстановление-приложения
Описание
Возвращает приложение к предыдущей рабочей версии. Вы можете восстановить приложение, если подозреваете, что оно застряло в переходном состоянии или в состоянии выполнения.
Вы можете восстановить приложение только если оно находится в статусах UPDATING , AUTOSCALING или RUNNING.
При восстановлении приложения данные состояния загружаются из последней успешной моментальной копии. Если у приложения нет моментальных копий, Управляемая служба Apache Flink отклонит запрос на восстановление.
См. также: Документацию API AWS
Синтаксис
rollback-application
--application-name <value>
--current-application-version-id <value>
[--cli-input-json | --cli-input-yaml]
[--generate-cli-skeleton <value>]
[--debug]
[--endpoint-url <value>]
[--no-verify-ssl]
[--no-paginate]
[--output <value>]
[--query <value>]
[--profile <value>]
[--region <value>]
[--version <value>]
[--color <value>]
[--no-sign-request]
[--ca-bundle <value>]
[--cli-read-timeout <value>]
[--cli-connect-timeout <value>]
[--cli-binary-format <value>]
[--no-cli-pager]
[--cli-auto-prompt]
[--no-cli-auto-prompt]
Параметры
--application-name (строка)
--current-application-version-id (целое число)
--cli-input-json | --cli-input-yaml (строка) Считывает аргументы из предоставленной строки JSON. Строка JSON следует формату, предоставленному в --generate-cli-skeleton. Если на командной строке указаны другие аргументы, эти значения переопределят значения, предоставленные в JSON. Невозможно передавать произвольные двоичные значения с помощью значения, предоставленного в JSON, поскольку строка будет взята буквально. Это не может быть указано вместе с --cli-input-yaml.
--generate-cli-skeleton (строка) Выводит JSON-скелет в стандартный вывод без отправки запроса API. Если указано без значения или со значением input, выводит пример входного JSON, который можно использовать в качестве аргумента для --cli-input-json. Аналогично, если указано yaml-input, будет напечатан пример входного YAML, который можно использовать с --cli-input-yaml. Если указано значение output, он проверяет входные данные команды и возвращает пример выходного JSON для этой команды. Сгенерированный JSON-скелет не является стабильным между версиями AWS CLI, и нет гарантий обратной совместимости в сгенерированном JSON-скелете.
Глобальные параметры
--debug (логическое значение)
Включить отладочную запись.
--endpoint-url (строка)
Переопределить URL по умолчанию команды заданным URL.
--no-verify-ssl (логическое значение)
По умолчанию AWS CLI использует SSL при общении с AWS-сервисами. Для каждого SSL-соединения AWS CLI будет проверять сертификаты SSL. Этот параметр переопределяет поведение проверки сертификатов SSL по умолчанию.
--no-paginate (логическое значение)
Отключить автоматическую постраничную навигацию. Если автоматическая постраничная навигация отключена, AWS CLI сделает только один вызов для первой страницы результатов.
--output (строка)
Стиль форматирования вывода команды.
- json
- текст
- таблица
- yaml
- yaml-потоковый
--query (строка)
Запрос JMESPath для фильтрации данных ответа.
--profile (строка)
Использовать определенный профиль из вашего файла учетных данных.
--region (строка)
Использовать определенный регион. Переопределяет параметры конфигурации/среды.
--version (строка)
Отобразить версию данного инструмента.
--color (строка)
Включить/выключить цветной вывод.
- включено
- выключено
- автоматически
--no-sign-request (логическое значение)
Не подписывать запросы. Учетные данные не будут загружены, если этот аргумент указан.
--ca-bundle (строка)
Файл сертификата CA для проверки сертификатов SSL. Переопределяет параметры конфигурации/среды.
--cli-read-timeout (целое число)
Максимальное время чтения сокета в секундах. Если значение равно 0, чтение сокета будет выполняться блокирующим образом и без таймаута. Значение по умолчанию — 60 секунд.
--cli-connect-timeout (целое число)
Максимальное время подключения к сокету в секундах. Если значение равно 0, подключение к сокету будет выполняться блокирующим образом и без таймаута. Значение по умолчанию — 60 секунд.
--cli-binary-format (строка)
Стиль форматирования, который будет использоваться для двоичных блоков. Формат по умолчанию — base64. Формат base64 ожидает, что двоичные блоки будут предоставлены в виде закодированной в base64 строки. Формат raw-in-base64-out сохраняет совместимость с поведением AWS CLI V1, и двоичные значения должны передаваться буквально. При предоставлении содержимого из файла, которое отображается на двоичный блок fileb:// всегда будет обрабатываться как двоичное и использовать содержимое файла непосредственно, независимо от параметра cli-binary-format. При использовании file:// содержимое файла должно быть должным образом отформатировано для настроенного cli-binary-format.
- base64
- raw-in-base64-out
--no-cli-pager (логическое значение)
Отключить пейджер CLI для вывода.
--cli-auto-prompt (логическое значение)
Автоматически запрашивать параметры ввода CLI.
--no-cli-auto-prompt (логическое значение)
Отключить автоматическую запрос параметров ввода CLI.
Вывод
ApplicationDetail -> (структура)
Описание приложения, включая Amazon Resource Name (ARN) приложения, статус, последнюю версию и конфигурации ввода и вывода.
ApplicationARN -> (строка)
ApplicationDescription -> (строка)
ApplicationName -> (строка)
RuntimeEnvironment -> (строка)
ServiceExecutionRole -> (строка)
ApplicationStatus -> (строка)
ApplicationVersionId -> (целое число)
ApplicationVersionId каждый раз при обновлении приложения.CreateTimestamp -> (метка времени)
LastUpdateTimestamp -> (метка времени)
ApplicationConfigurationDescription -> (структура)
Описание деталей кода приложения и параметров запуска для приложения Managed Service for Apache Flink.
SqlApplicationConfigurationDescription -> (структура)
Подробности о входах, выходах и источниках справочных данных для приложения Kinesis Data Analytics на основе SQL.
InputDescriptions -> (список)
Массив объектов InputDescription, описывающих входные потоки, используемые приложением.
(структура)
Описание конфигурации ввода приложения для приложения Kinesis Data Analytics на основе SQL.
InputId -> (строка)
NamePrefix -> (строка)
InAppStreamNames -> (список)
Возвращает имена потоков внутри приложения, которые сопоставлены с источником потока.
(строка)
InputProcessingConfigurationDescription -> (структура)
Описание препроцессора, который выполняется над записями в этом входе перед запуском кода приложения.
InputLambdaProcessorDescription -> (структура)
Предоставляет конфигурационную информацию об ассоциированном InputLambdaProcessorDescription
ResourceARN -> (строка)
ARN функции Amazon Lambda, используемой для предварительной обработки записей в потоке.
Примечание
Чтобы указать более раннюю версию функции Lambda, чем последнюю, включите версию функции Lambda в ARN функции Lambda. Дополнительную информацию о Lambda ARN см. в примере ARN: Amazon LambdaRoleARN -> (строка)
ARN роли IAM, используемой для доступа к функции Amazon Lambda.
Примечание
Предоставлено для обратной совместимости. Приложения, созданные с использованием текущей версии API, имеют роль выполнения службы на уровне приложения, а не на уровне ресурса.KinesisStreamsInputDescription -> (структура)
Если поток данных Kinesis настроен в качестве источника потока, предоставляет Amazon Resource Name (ARN) потока данных Kinesis.
ResourceARN -> (строка)
RoleARN -> (строка)
ARN роли IAM, которую Kinesis Data Analytics может принять для доступа к потоку.
Примечание
Предоставлено для обратной совместимости. Приложения, созданные с использованием текущей версии API, имеют роль выполнения службы на уровне приложения, а не на уровне ресурса.KinesisFirehoseInputDescription -> (структура)
Если поток доставки Kinesis Data Firehose настроен в качестве источника потока, предоставляет ARN потока доставки.
ResourceARN -> (строка)
RoleARN -> (строка)
ARN роли IAM, которую Kinesis Data Analytics принимает для доступа к потоку.
Примечание
Предоставлено для обратной совместимости. Приложения, созданные с использованием текущей версии API, имеют роль выполнения службы на уровне приложения, а не на уровне ресурса.InputSchema -> (структура)
Описание формата данных в источнике потока и того, как каждый элемент данных сопоставляется с соответствующими столбцами в потоке внутри приложения, который создается.
RecordFormat -> (структура)
Указывает формат записей в источнике потока.
RecordFormatType -> (строка)
MappingParameters -> (структура)
При настройке ввода приложения во время создания или обновления приложения предоставляет дополнительную информацию о сопоставлении, специфическую для формата записи (например, JSON, CSV или поля записей, разделяемые каким-либо разделителем) в источнике потока.
JSONMappingParameters -> (структура)
Предоставляет дополнительную информацию о сопоставлении, когда формат записи — JSON в источнике потока.
RecordRowPath -> (строка)
CSVMappingParameters -> (структура)
Предоставляет дополнительную информацию о сопоставлении, когда формат записи использует разделители (например, CSV).
RecordRowDelimiter -> (строка)
RecordColumnDelimiter -> (строка)
RecordEncoding -> (строка)
RecordColumns -> (список)
Список RecordColumn объектов.
(структура)
Для приложения Kinesis Data Analytics на основе SQL описывает сопоставление каждого элемента данных в источнике потока с соответствующим столбцом в потоке внутри приложения.
Также используется для описания формата источника справочных данных.
Name -> (строка)
Mapping -> (строка)
SqlType -> (строка)
InputParallelism -> (структура)
Описание настроенного параллелизма (количество потоков внутри приложения, сопоставленных с источником потока).
Count -> (целое число)
InputStartingPositionConfiguration -> (структура)
Точка, с которой приложение настраивается для чтения из входного потока.
InputStartingPosition -> (строка)
Точка начала чтения в потоке.
-
NOW- Начать чтение сразу после последней записи в потоке и начать с метки времени запроса, выданного клиентом. -
TRIM_HORIZON- Начать чтение с последней необрезанной записи в потоке, которая является самой старой записью, доступной в потоке. Этот вариант недоступен для потока доставки Amazon Kinesis Data Firehose. -
LAST_STOPPED_POINT- Возобновить чтение с места, где приложение последний раз остановилось.
OutputDescriptions -> (список)
Массив объектов OutputDescription, описывающих потоки назначения, используемые приложением.
(структура)
Для приложения Kinesis Data Analytics на основе SQL описывает конфигурацию вывода приложения, которая включает имя потока внутри приложения и место назначения, куда записываются данные потока. Место назначения может быть потоком данных Kinesis или потоком доставки Kinesis Data Firehose.
OutputId -> (строка)
Name -> (строка)
KinesisStreamsOutputDescription -> (структура)
Описывает поток данных Kinesis, настроенный в качестве места назначения для записи вывода.
ResourceARN -> (строка)
RoleARN -> (строка)
ARN роли IAM, которую Kinesis Data Analytics может принять для доступа к потоку.
Примечание
Предоставлено для обратной совместимости. Приложения, созданные с использованием текущей версии API, имеют роль выполнения службы на уровне приложения, а не на уровне ресурса.KinesisFirehoseOutputDescription -> (структура)
Описывает поток доставки Kinesis Data Firehose, настроенный в качестве места назначения для записи вывода.
ResourceARN -> (строка)
RoleARN -> (строка)
ARN роли IAM, которую Kinesis Data Analytics может принять для доступа к потоку.
Примечание
Предоставлено для обратной совместимости. Приложения, созданные с использованием текущей версии API, имеют роль выполнения службы на уровне приложения, а не на уровне ресурса.LambdaOutputDescription -> (структура)
Описывает функцию Lambda, настроенную в качестве места назначения для записи вывода.
ResourceARN -> (строка)
RoleARN -> (строка)
ARN роли IAM, которую Kinesis Data Analytics может принять для записи в целевую функцию.
Примечание
Предоставлено для обратной совместимости. Приложения, созданные с использованием текущей версии API, имеют роль выполнения службы на уровне приложения, а не на уровне ресурса.DestinationSchema -> (структура)
Формат данных, используемый для записи данных в место назначения.
RecordFormatType -> (строка)
ReferenceDataSourceDescriptions -> (список)
Массив объектов ReferenceDataSourceDescription, описывающих источники справочных данных, используемые приложением.
(структура)
Для приложения Kinesis Data Analytics на основе SQL описывает источник справочных данных, настроенный для приложения.
ReferenceId -> (строка)
TableName -> (строка)
S3ReferenceDataSourceDescription -> (структура)
Предоставляет имя ведра Amazon S3 и имя ключа объекта, содержащего справочные данные.
BucketARN -> (строка)
FileKey -> (строка)
ReferenceRoleARN -> (строка)
Идентификатор ресурса (ARN) роли IAM, которую Kinesis Data Analytics может принять, чтобы прочитать объект Amazon S3 от вашего имени для заполнения таблицы справочных данных в приложении.
Примечание
Предоставлено для обратной совместимости. Приложения, созданные с использованием текущей версии API, имеют роль выполнения сервиса на уровне приложения, а не на уровне ресурса.ReferenceSchema -> (структура)
Описывает формат данных в источнике потоковой передачи и то, как каждый элемент данных сопоставляется с соответствующими столбцами, созданными в потоке приложения.
RecordFormat -> (структура)
Определяет формат записей в источнике потоковой передачи.
RecordFormatType -> (строка)
MappingParameters -> (структура)
При настройке входных данных приложения во время создания или обновления приложения предоставляет дополнительную информацию о сопоставлении, специфичную для формата записей (например, JSON, CSV или записи, разделенные каким-либо разделителем) в источнике потоковой передачи.
JSONMappingParameters -> (структура)
Предоставляет дополнительную информацию о сопоставлении, когда JSON является форматом записи в источнике потоковой передачи.
RecordRowPath -> (строка)
CSVMappingParameters -> (структура)
Предоставляет дополнительную информацию о сопоставлении, когда формат записи использует разделители (например, CSV).
RecordRowDelimiter -> (строка)
RecordColumnDelimiter -> (строка)
RecordEncoding -> (строка)
RecordColumns -> (список)
Список объектов RecordColumn.
(структура)
Для приложения Kinesis Data Analytics на основе SQL описывает сопоставление каждого элемента данных в источнике потоковой передачи с соответствующим столбцом в потоке приложения.
Также используется для описания формата источника справочных данных.
Name -> (строка)
Mapping -> (строка)
SqlType -> (строка)
ApplicationCodeConfigurationDescription -> (структура)
Подробная информация о коде приложения для приложения Managed Service для Apache Flink.
CodeContentType -> (строка)
CodeContentDescription -> (структура)
Описывает сведения о расположении и формате кода приложения.
TextContent -> (строка)
CodeMD5 -> (строка)
CodeSize -> (длинное целое число)
S3ApplicationCodeLocationDescription -> (структура)
Идентификатор ресурса Amazon (ARN) ведра S3, имя ключа и версия объекта кода приложения, хранящегося в Amazon S3.
BucketARN -> (строка)
FileKey -> (строка)
ObjectVersion -> (строка)
RunConfigurationDescription -> (структура)
Подробная информация о начальных свойствах для приложения Managed Service для Apache Flink.
ApplicationRestoreConfigurationDescription -> (структура)
Описывает поведение восстановления перезапускающегося приложения.
ApplicationRestoreType -> (строка)
SnapshotName -> (строка)
RESTORE_FROM_CUSTOM_SNAPSHOT указано для ApplicationRestoreType .FlinkRunConfigurationDescription -> (структура)
Описывает начальные параметры для приложения Managed Service для Apache Flink.
AllowNonRestoredState -> (булево)
При восстановлении из снимка указывает, разрешено ли временному выполнению пропускать состояние, которое не может быть отображено в новой программе. Это произойдет, если программа обновлена между снимками для удаления состоятельных параметров и данные состояния в снимке больше не соответствуют допустимым данным приложения. Дополнительную информацию см. в документации Apache Flink по разрешению невосстановленного состояния.
Примечание
Это значение по умолчанию равноfalse . Если вы обновляете приложение, не указывая этот параметр, AllowNonRestoredState будет установлено в false , даже если ранее оно было установлено в true .FlinkApplicationConfigurationDescription -> (структура)
Подробности о приложении Managed Service для Apache Flink.
CheckpointConfigurationDescription -> (структура)
Описывает конфигурацию создания контрольных точек приложения. Создание контрольных точек — это процесс сохранения состояния приложения для обеспечения отказоустойчивости.
ConfigurationType -> (строка)
Описывает, использует ли приложение поведение по умолчанию для создания контрольных точек в Managed Service для Apache Flink.
Примечание
Если это значение установлено в DEFAULT, приложение будет использовать следующие значения, даже если они установлены другими значениями с помощью API или кода приложения:
- CheckpointingEnabled: true
- CheckpointInterval: 60000
- MinPauseBetweenCheckpoints: 5000
CheckpointingEnabled -> (булево)
Описывает, включено ли создание контрольных точек для приложения Managed Service для Apache Flink.
Примечание
ЕслиCheckpointConfiguration.ConfigurationType равно DEFAULT, приложение будет использовать значение CheckpointingEnabled, равное true, даже если это значение установлено другим значением с помощью данного API или в коде приложения.CheckpointInterval -> (длинное целое число)
Описывает интервал в миллисекундах между операциями создания контрольных точек.
Примечание
ЕслиCheckpointConfiguration.ConfigurationType равно DEFAULT, приложение будет использовать значение CheckpointInterval, равное 60000, даже если это значение установлено другим значением с помощью данного API или в коде приложения.MinPauseBetweenCheckpoints -> (длинное целое число)
Описывает минимальное время в миллисекундах после завершения операции создания контрольной точки, через которое может начаться новая операция создания контрольной точки.
Примечание
ЕслиCheckpointConfiguration.ConfigurationType равно DEFAULT, приложение будет использовать значение MinPauseBetweenCheckpoints, равное 5000, даже если это значение установлено с помощью данного API или в коде приложения.MonitoringConfigurationDescription -> (структура)
Описывает параметры конфигурации для ведения журнала Amazon CloudWatch для приложения.
ConfigurationType -> (строка)
MetricsLevel -> (строка)
LogLevel -> (строка)
ParallelismConfigurationDescription -> (структура)
Описывает параметры того, как приложение выполняет несколько задач одновременно.
ConfigurationType -> (строка)
Parallelism -> (целое число)
AutoScalingEnabled установлено в True, то Managed Service для Apache Flink может увеличить значение CurrentParallelism в ответ на нагрузку приложения. Сервис может увеличить CurrentParallelism до максимального параллелизма, который равен ParalellismPerKPU умноженному на максимальное количество KPU для приложения. Максимальное количество KPU для приложения по умолчанию составляет 32 и может быть увеличено путем запроса увеличения лимита. Если нагрузка приложения уменьшится, сервис может уменьшить значение CurrentParallelism до значения по умолчанию Parallelism.ParallelismPerKPU -> (целое число)
CurrentParallelism -> (целое число)
AutoScalingEnabled установлено в True, Managed Service для Apache Flink может увеличить это значение в ответ на нагрузку приложения. Сервис может увеличить это значение до максимального параллелизма, который равен ParalellismPerKPU умноженному на максимальное количество KPU для приложения. Максимальное количество KPU для приложения по умолчанию составляет 32 и может быть увеличено путем запроса увеличения лимита. Если нагрузка приложения уменьшится, сервис может уменьшить значение CurrentParallelism до значения по умолчанию Parallelism.AutoScalingEnabled -> (булево)
JobPlanDescription -> (строка)
EnvironmentPropertyDescriptions -> (структура)
Описывает свойства выполнения для приложения Managed Service для Apache Flink.
PropertyGroupDescriptions -> (список)
Описывает группы свойств выполнения.
(структура)
Ключево-значимые пары свойств, передаваемые в приложение.
PropertyGroupId -> (строка)
PropertyMap -> (отображение)
Описывает значение ключево-значимой пары свойств выполнения приложения.
key -> (строка)
value -> (строка)
ApplicationSnapshotConfigurationDescription -> (структура)
Описывает, включены ли моментальные снимки для приложения Managed Service для Apache Flink.
SnapshotsEnabled -> (булево)
ApplicationSystemRollbackConfigurationDescription -> (структура)
Описывает конфигурацию отката системы для приложения Managed Service для Apache Flink
RollbackEnabled -> (булево)
VpcConfigurationDescriptions -> (список)
Массив описаний конфигураций VPC, доступных для приложения.
(структура)
Описывает параметры VPC, используемого приложением.
VpcConfigurationId -> (строка)
VpcId -> (строка)
SubnetIds -> (список)
Массив идентификаторов подсетей, используемых конфигурацией VPC.
(строка)
SecurityGroupIds -> (список)
Массив идентификаторов групп безопасности, используемых конфигурацией VPC.
(строка)
ZeppelinApplicationConfigurationDescription -> (структура)
Параметры конфигурации для блокнота Managed Service для Apache Flink Studio.
MonitoringConfigurationDescription -> (структура)
Конфигурация мониторинга блокнота Managed Service для Apache Flink Studio.
LogLevel -> (строка)
CatalogConfigurationDescription -> (структура)
Каталог данных Amazon Glue, связанный с блокнотом Managed Service для Apache Flink Studio.
GlueDataCatalogConfigurationDescription -> (структура)
Параметры конфигурации для базы данных Amazon Glue по умолчанию. Вы используете эту базу данных для запросов SQL, которые вы пишете в блокноте Managed Service для Apache Flink Studio.
DatabaseARN -> (строка)
DeployAsApplicationConfigurationDescription -> (структура)
Параметры, необходимые для развертывания блокнота Managed Service для Apache Flink Studio в качестве приложения с долговременным состоянием.
S3ContentLocationDescription -> (структура)
Расположение, содержащее данные, необходимые для задания приложения Amazon Data Analytics.
BucketARN -> (строка)
BasePath -> (строка)
CustomArtifactsConfigurationDescription -> (список)
Пользовательские артефакты — это зависимости JAR и пользовательские функции (UDF).
(структура)
Определяет зависимость JAR или JAR пользовательских функций.
ArtifactType -> (строка)
UDF обозначает пользовательские функции. Этот тип артефакта должен находиться в корзине S3. DEPENDENCY_JAR может находиться как в Maven, так и в корзине S3.S3ContentLocationDescription -> (структура)
Для приложения Managed Service для Apache Flink предоставляет описание объекта Amazon S3, включая Amazon Resource Name (ARN) корзины S3, имя объекта Amazon S3, содержащего данные, и номер версии объекта Amazon S3, содержащего данные.
BucketARN -> (строка)
FileKey -> (строка)
ObjectVersion -> (строка)
MavenReferenceDescription -> (структура)
Параметры, необходимые для задания зависимости Maven.
GroupId -> (строка)
ArtifactId -> (строка)
Version -> (строка)
CloudWatchLoggingOptionDescriptions -> (список)
Описывает параметры ведения журнала Amazon CloudWatch для приложения.
(структура)
Описывает параметр ведения журнала Amazon CloudWatch.
CloudWatchLoggingOptionId -> (строка)
LogStreamARN -> (строка)
RoleARN -> (строка)
IAM ARN роли для отправки сообщений приложения.
Примечание
Предоставлено для обратной совместимости. Приложения, созданные с текущей версией API, имеют роль выполнения сервиса на уровне приложения, а не на уровне ресурса.ApplicationMaintenanceConfigurationDescription -> (структура)
Подробности конфигурации технического обслуживания приложения.
ApplicationMaintenanceWindowStartTime -> (строка)
ApplicationMaintenanceWindowEndTime -> (строка)
ApplicationVersionUpdatedFrom -> (длинное целое число)
ApplicationVersionRolledBackFrom -> (длинное целое число)
RollbackApplication.ApplicationVersionCreateTimestamp -> (временная метка)
ConditionalToken -> (string)
ApplicationVersionRolledBackTo -> (long)
ApplicationMode -> (string)
INTERACTIVE . Однако для Управляемой службы для приложения Apache Flink режим является необязательным.OperationId -> (string)
© Copyright 2025, Amazon Web Services. Created using Sphinx.