create-application

Описание

Создаёт управляемое приложение Apache Flink. Для получения информации о создании управляемого приложения Apache Flink, см. Создание приложения.

См. также: Документацию API AWS

Синтаксис

  create-application
--application-name <value>
[--application-description <value>]
--runtime-environment <value>
--service-execution-role <value>
[--application-configuration <value>]
[--cloud-watch-logging-options <value>]
[--tags <value>]
[--application-mode <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 (строка)

Имя вашего приложения (например, sample-app ).

--application-description (строка)

Краткое описание приложения.

--runtime-environment (строка)

Вычислительная среда для приложения.

Возможные значения:

SQL-1_0
FLINK-1_6
FLINK-1_8
ZEPPELIN-FLINK-1_0
FLINK-1_11
FLINK-1_13
ZEPPELIN-FLINK-2_0
FLINK-1_15
ZEPPELIN-FLINK-3_0
FLINK-1_18
FLINK-1_19
FLINK-1_20

--service-execution-role (строка)

Роль IAM, используемая приложением для доступа к потокам Kinesis, потокам доставки Kinesis Data Firehose, объектам Amazon S3 и другим внешним ресурсам.

--application-configuration (структура)

Используйте этот параметр для настройки приложения.

SqlApplicationConfiguration -> (структура)

Параметры создания и обновления приложения на основе SQL.

Inputs -> (список)

Массив объектов Input, описывающих входные потоки, используемые приложением.

(структура)

При настройке входных данных приложения для приложения Kinesis Data Analytics на основе SQL, вы указываете источник потока, имя потока внутри приложения, которое создается, и соответствие между ними.

NamePrefix -> (строка)

Префикс имени для создания потока внутри приложения. Предположим, вы указали префикс «MyInApplicationStream ». Kinesis Data Analytics затем создаст один или несколько (в соответствии с указанным вами значением InputParallelism) потоков внутри приложения с именами «MyInApplicationStream_001 », «MyInApplicationStream_002 » и так далее.

InputProcessingConfiguration -> (структура)

InputProcessingConfiguration для входа. Обработчик входов преобразует записи по мере их получения из потока, прежде чем выполнится код SQL приложения. В настоящее время единственной доступной конфигурацией обработки входов является InputLambdaProcessor.

InputLambdaProcessor -> (структура)

InputLambdaProcessor, используемый для предварительной обработки записей в потоке перед обработкой кодом вашего приложения.

ResourceARN -> (строка)

ARN функции Amazon Lambda, которая обрабатывает записи в потоке.

Примечание

Чтобы указать более раннюю версию функции Lambda, чем последнюю, включите версию функции Lambda в ARN функции Lambda. Дополнительную информацию о Lambda ARN см. в Примеры ARN: Amazon Lambda

KinesisStreamsInput -> (структура)

Если источником потока является поток данных Amazon Kinesis, указывает Amazon Resource Name (ARN) потока.

ResourceARN -> (строка)

ARN входного потока Kinesis данных для чтения.

KinesisFirehoseInput -> (структура)

Если источником потока является поток доставки Amazon Kinesis Data Firehose, указывает ARN потока доставки.

ResourceARN -> (строка)

Amazon Resource Name (ARN) потока доставки.

InputParallelism -> (структура)

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

Count -> (целое число)

Количество потоков внутри приложения, которые необходимо создать.

InputSchema -> (структура)

Описывает формат данных в источнике потока и то, как каждый элемент данных отображается на соответствующие столбцы в потоке внутри приложения, который создаётся.

Также используется для описания формата источника справочных данных.

RecordFormat -> (структура)

Указывает формат записей в источнике потока.

RecordFormatType -> (строка)

Тип формата записей.

MappingParameters -> (структура)

При настройке входных данных приложения при создании или обновлении приложения предоставляется дополнительная информация о сопоставлении, специфичная для формата записей (например, JSON, CSV или поля записей, разделяемые разделителем) в источнике потока.

JSONMappingParameters -> (структура)

Предоставляет дополнительную информацию о сопоставлении, когда формат записей JSON в источнике потока.

RecordRowPath -> (строка)

Путь к родительскому элементу верхнего уровня, который содержит записи.

CSVMappingParameters -> (структура)

Предоставляет дополнительную информацию о сопоставлении, когда формат записей использует разделители (например, CSV).

RecordRowDelimiter -> (строка)

Разделитель строк. Например, в формате CSV, ‘n’ — типичный разделитель строк.

RecordColumnDelimiter -> (строка)

Разделитель столбцов. Например, в формате CSV, запятая (“,”) — типичный разделитель столбцов.

RecordEncoding -> (строка)

Указывает кодировку записей в источнике потока. Например, UTF-8.

RecordColumns -> (список)

Список RecordColumn объектов.

(структура)

Для приложения Kinesis Data Analytics на основе SQL описывает отображение каждого элемента данных в источнике потока на соответствующий столбец во входном потоке внутри приложения.

Также используется для описания формата источника справочных данных.

Name -> (строка)

Имя столбца, созданного во входном потоке внутри приложения или справочной таблице.

Mapping -> (строка)

Ссылка на элемент данных во входном потоке или источнике справочных данных.

SqlType -> (строка)

Тип столбца, созданного во входном потоке внутри приложения или справочной таблице.

Outputs -> (список)

Массив объектов Output, описывающих выходные потоки, используемые приложением.

(структура)

Описывает конфигурацию вывода приложения Kinesis Data Analytics на основе SQL, в котором вы определяете поток внутри приложения и место назначения, куда вы хотите записать данные из потока внутри приложения. Место назначения может быть потоком данных Kinesis или потоком доставки Kinesis Data Firehose.

Name -> (строка)

Имя потока внутри приложения.

KinesisStreamsOutput -> (структура)

Указывает поток данных Kinesis в качестве места назначения.

ResourceARN -> (строка)

ARN целевого потока Kinesis данных для записи.

KinesisFirehoseOutput -> (структура)

Указывает поток доставки Kinesis Data Firehose в качестве места назначения.

ResourceARN -> (строка)

ARN целевого потока доставки для записи.

LambdaOutput -> (структура)

Указывает функцию Amazon Lambda в качестве места назначения.

ResourceARN -> (строка)

Amazon Resource Name (ARN) целевой функции Lambda для записи.

Примечание

DestinationSchema -> (структура)

Описывает формат данных при записи записей в место назначения.

RecordFormatType -> (строка)

Указывает формат записей в выходном потоке.

ReferenceDataSources -> (список)

Массив объектов ReferenceDataSource, описывающих источники справочных данных, используемые приложением.

(структура)

Для приложения Kinesis Data Analytics на основе SQL описывает источник справочных данных, предоставляя информацию о источнике (имя ведра Amazon S3 и имя ключа объекта), имя полученной таблицы внутри приложения, которое создаётся, и необходимую схему для сопоставления элементов данных в объекте Amazon S3 со столбцами в таблице внутри приложения.

TableName -> (строка)

Имя таблицы внутри приложения для создания.

S3ReferenceDataSource -> (структура)

Указывает ведро S3 и объект, содержащий справочные данные. Приложение Kinesis Data Analytics на основе SQL загружает справочные данные только один раз. Если данные изменяются, вы вызываете операцию UpdateApplication, чтобы инициировать перезагрузку данных в ваше приложение.

BucketARN -> (строка)

Amazon Resource Name (ARN) ведра S3.

FileKey -> (строка)

Имя ключа объекта, содержащего справочные данные.

ReferenceSchema -> (структура)

Описывает формат данных в источнике потока и то, как каждый элемент данных сопоставляется с соответствующими столбцами, созданными в потоке внутри приложения.

RecordFormat -> (структура)

Указывает формат записей в источнике потока.

RecordFormatType -> (строка)

Тип формата записей.

MappingParameters -> (структура)

JSONMappingParameters -> (структура)

Предоставляет дополнительную информацию о сопоставлении, когда формат записей JSON в источнике потока.

RecordRowPath -> (строка)

Путь к родительскому элементу верхнего уровня, который содержит записи.

CSVMappingParameters -> (структура)

RecordRowDelimiter -> (строка)

Разделитель строк. Например, в формате CSV, ‘n’ — типичный разделитель строк.

RecordColumnDelimiter -> (строка)

Разделитель столбцов. Например, в формате CSV, запятая (“,”) — типичный разделитель столбцов.

RecordEncoding -> (строка)

Указывает кодировку записей в источнике потока. Например, UTF-8.

RecordColumns -> (список)

Список RecordColumn объектов.

(структура)

Также используется для описания формата источника справочных данных.

Name -> (строка)

Имя столбца, созданного во входном потоке внутри приложения или справочной таблице.

Mapping -> (строка)

Ссылка на элемент данных во входном потоке или источнике справочных данных.

SqlType -> (строка)

Тип столбца, созданного во входном потоке внутри приложения или справочной таблице.

FlinkApplicationConfiguration -> (структура)

Параметры создания и обновления приложения Managed Service for Apache Flink.

CheckpointConfiguration -> (структура)

Описывает конфигурацию контрольных точек приложения. Контрольные точки — это процесс сохранения состояния приложения для обеспечения отказоустойчивости. Дополнительную информацию см. в документации Apache Flink по контрольным точкам для отказоустойчивости.

ConfigurationType -> (строка)

Определяет, использует ли приложение поведение по умолчанию для контрольных точек Managed Service for Apache Flink. Необходимо установить это свойство в CUSTOM, чтобы установить параметры CheckpointingEnabled, CheckpointInterval или MinPauseBetweenCheckpoints.

Примечание

Если это значение установлено в DEFAULT, приложение будет использовать следующие значения, даже если они установлены в других значениях с помощью API или кода приложения:

CheckpointingEnabled: true
CheckpointInterval: 60000
MinPauseBetweenCheckpoints: 5000

CheckpointingEnabled -> (булево)

Описывает, включено ли создание контрольных точек для приложения Managed Service for Apache Flink.

Примечание

Если CheckpointConfiguration.ConfigurationType равно DEFAULT, приложение будет использовать значение CheckpointingEnabled, равное true, даже если это значение установлено в другом значении с помощью этого API или в коде приложения.

CheckpointInterval -> (длинное целое)

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

Примечание

Если CheckpointConfiguration.ConfigurationType равно DEFAULT, приложение будет использовать значение CheckpointInterval, равное 60000, даже если это значение установлено в другом значении с помощью этого API или в коде приложения.

MinPauseBetweenCheckpoints -> (длинное целое)

Описывает минимальное время в миллисекундах после завершения операции создания контрольной точки, через которое может начаться новая операция создания контрольной точки. Если операция создания контрольной точки занимает больше времени, чем CheckpointInterval, приложение выполняет непрерывные операции создания контрольных точек. Дополнительную информацию см. в документации Apache Flink по настройке создания контрольных точек.

Примечание

Если CheckpointConfiguration.ConfigurationType равно DEFAULT, приложение будет использовать значение MinPauseBetweenCheckpoints, равное 5000, даже если это значение установлено с помощью этого API или в коде приложения.

MonitoringConfiguration -> (структура)

Описывает параметры конфигурации ведения журнала Amazon CloudWatch для приложения.

ConfigurationType -> (строка)

Описывает, использовать ли конфигурацию ведения журнала CloudWatch по умолчанию для приложения. Необходимо установить это свойство в CUSTOM, чтобы установить параметры LogLevel или MetricsLevel.

MetricsLevel -> (строка)

Описывает точность журналов CloudWatch для приложения. Уровень Parallelism не рекомендуется для приложений с параллелизмом более 64 из-за чрезмерных затрат.

LogLevel -> (строка)

Описывает подробность журналов CloudWatch для приложения.

ParallelismConfiguration -> (структура)

Описывает параметры того, как приложение выполняет несколько задач одновременно.

ConfigurationType -> (строка)

Описывает, использует ли приложение значение параллелизма по умолчанию для службы Managed Service for Apache Flink. Необходимо установить это свойство в CUSTOM, чтобы изменить свойства приложения AutoScalingEnabled, Parallelism или ParallelismPerKPU.

Parallelism -> (целое число)

Описывает начальное количество параллельных задач, которые может выполнить приложение Managed Service for Apache Flink. Если AutoScalingEnabled установлено в True, Managed Service for Apache Flink увеличивает значение CurrentParallelism в ответ на нагрузку приложения. Служба может увеличить значение CurrentParallelism до максимального параллелизма, который составляет ParalellismPerKPU кратное максимальному числу KPUs для приложения. Максимальное число KPUs для приложения по умолчанию равно 32 и может быть увеличено путем запроса увеличения лимита. Если нагрузка приложения уменьшается, служба может уменьшить значение CurrentParallelism до значения Parallelism.

ParallelismPerKPU -> (целое число)

Описывает количество параллельных задач, которые может выполнить приложение Managed Service for Apache Flink на каждый Kinesis Processing Unit (KPU), используемый приложением. Дополнительную информацию о KPU см. в разделе Цены на Amazon Managed Service for Apache Flink.

AutoScalingEnabled -> (булево)

Описывает, может ли служба Managed Service for Apache Flink увеличить параллелизм приложения в ответ на увеличение пропускной способности.

EnvironmentProperties -> (структура)

Описывает свойства выполнения для приложения Managed Service for Apache Flink.

PropertyGroups -> (список)

Описывает группы свойств выполнения.

(структура)

Ключевые пары свойств, передаваемые в приложение.

PropertyGroupId -> (строка)

Описывает ключ пары ключ-значение свойства выполнения приложения.

PropertyMap -> (отображение)

Описывает значение пары ключ-значение свойства выполнения приложения.

key -> (строка)

value -> (строка)

ApplicationCodeConfiguration -> (структура)

Параметры местоположения и типа кода для приложения Managed Service for Apache Flink.

CodeContent -> (структура)

Местоположение и тип кода приложения.

TextContent -> (строка)

Код в текстовом формате для приложения Managed Service for Apache Flink.

ZipFileContent -> (байтовый массив)

Код в формате zip для приложения Managed Service for Apache Flink.

S3ContentLocation -> (структура)

Информация об Amazon S3-бакете, содержащем код приложения.

BucketARN -> (строка)

Amazon Resource Name (ARN) для S3-бакета, содержащего код приложения.

FileKey -> (строка)

Ключ файла для объекта, содержащего код приложения.

ObjectVersion -> (строка)

Версия объекта, содержащего код приложения.

CodeContentType -> (строка)

Указывает, находится ли содержимое кода в текстовом или zip-формате.

ApplicationSnapshotConfiguration -> (структура)

Описывает, включены ли снимки для приложения Managed Service for Apache Flink.

SnapshotsEnabled -> (булево)

Описывает, включены ли снимки для приложения Managed Service for Apache Flink.

ApplicationSystemRollbackConfiguration -> (структура)

Описывает конфигурацию отката системы для приложения Managed Service for Apache Flink.

RollbackEnabled -> (булево)

Описывает, включены ли откаты системы для приложения Managed Service for Apache Flink.

VpcConfigurations -> (список)

Массив описаний конфигураций VPC, доступных для приложения.

(структура)

Описывает параметры VPC, используемого приложением.

SubnetIds -> (список)

Массив идентификаторов подсетей, используемых конфигурацией VPC.

(строка)

SecurityGroupIds -> (список)

Массив идентификаторов групп безопасности, используемых конфигурацией VPC.

(строка)

ZeppelinApplicationConfiguration -> (структура)

Параметры конфигурации для блокнота Managed Service for Apache Flink Studio.

MonitoringConfiguration -> (структура)

Конфигурация мониторинга блокнота Managed Service for Apache Flink Studio.

LogLevel -> (строка)

Подробность журналов CloudWatch для приложения.

CatalogConfiguration -> (структура)

Amazon Glue Data Catalog, используемый в запросах в блокноте Managed Service for Apache Flink Studio.

GlueDataCatalogConfiguration -> (структура)

Параметры конфигурации для базы данных Amazon Glue по умолчанию. Эта база данных используется для запросов Apache Flink SQL и преобразований API таблиц, которые вы пишете в блокноте Managed Service for Apache Flink Studio.

DatabaseARN -> (строка)

Amazon Resource Name (ARN) базы данных.

DeployAsApplicationConfiguration -> (структура)

Информация, необходимая для развертывания блокнота Managed Service for Apache Flink Studio в качестве приложения с долговременным состоянием.

S3ContentLocation -> (структура)

Описание объекта Amazon S3, содержащего приложение Amazon Data Analytics, включая Amazon Resource Name (ARN) S3-бакета, имя объекта Amazon S3, содержащего данные, и номер версии объекта Amazon S3, содержащего данные.

BucketARN -> (строка)

Amazon Resource Name (ARN) S3-бакета.

BasePath -> (строка)

Базовая директория S3-бакета.

CustomArtifactsConfiguration -> (список)

Пользовательские артефакты — это JAR-файлы зависимостей и пользовательские функции (UDF).

(структура)

Определяет JAR-файлы зависимостей, а также JAR-файлы, содержащие пользовательские функции (UDF).

ArtifactType -> (строка)

UDF обозначает пользовательские функции. Этот тип артефакта должен находиться в S3-бакете. DEPENDENCY_JAR может находиться как в Maven, так и в S3-бакете.

S3ContentLocation -> (структура)

Для приложения Managed Service for Apache Flink предоставляется описание объекта Amazon S3, включая Amazon Resource Name (ARN) S3-бакета, имя объекта Amazon S3, содержащего данные, и номер версии объекта Amazon S3, содержащего данные.

BucketARN -> (строка)

Amazon Resource Name (ARN) для S3-бакета, содержащего код приложения.

FileKey -> (строка)

Ключ файла для объекта, содержащего код приложения.

ObjectVersion -> (строка)

Версия объекта, содержащего код приложения.

MavenReference -> (структура)

Параметры, необходимые для полного указания ссылки Maven.

GroupId -> (строка)

Идентификатор группы ссылки Maven.

ArtifactId -> (строка)

Идентификатор артефакта ссылки Maven.

Version -> (строка)

Версия ссылки Maven.

Синтаксис JSON:

{
  "SqlApplicationConfiguration": {
    "Inputs": [
      {
        "NamePrefix": "string",
        "InputProcessingConfiguration": {
          "InputLambdaProcessor": {
            "ResourceARN": "string"
          }
        },
        "KinesisStreamsInput": {
          "ResourceARN": "string"
        },
        "KinesisFirehoseInput": {
          "ResourceARN": "string"
        },
        "InputParallelism": {
          "Count": integer
        },
        "InputSchema": {
          "RecordFormat": {
            "RecordFormatType": "JSON"|"CSV",
            "MappingParameters": {
              "JSONMappingParameters": {
                "RecordRowPath": "string"
              },
              "CSVMappingParameters": {
                "RecordRowDelimiter": "string",
                "RecordColumnDelimiter": "string"
              }
            }
          },
          "RecordEncoding": "string",
          "RecordColumns": [
            {
              "Name": "string",
              "Mapping": "string",
              "SqlType": "string"
            }
            ...
          ]
        }
      }
      ...
    ],
    "Outputs": [
      {
        "Name": "string",
        "KinesisStreamsOutput": {
          "ResourceARN": "string"
        },
        "KinesisFirehoseOutput": {
          "ResourceARN": "string"
        },
        "LambdaOutput": {
          "ResourceARN": "string"
        },
        "DestinationSchema": {
          "RecordFormatType": "JSON"|"CSV"
        }
      }
      ...
    ],
    "ReferenceDataSources": [
      {
        "TableName": "string",
        "S3ReferenceDataSource": {
          "BucketARN": "string",
          "FileKey": "string"
        },
        "ReferenceSchema": {
          "RecordFormat": {
            "RecordFormatType": "JSON"|"CSV",
            "MappingParameters": {
              "JSONMappingParameters": {
                "RecordRowPath": "string"
              },
              "CSVMappingParameters": {
                "RecordRowDelimiter": "string",
                "RecordColumnDelimiter": "string"
              }
            }
          },
          "RecordEncoding": "string",
          "RecordColumns": [
            {
              "Name": "string",
              "Mapping": "string",
              "SqlType": "string"
            }
            ...
          ]
        }
      }
      ...
    ]
  },
  "FlinkApplicationConfiguration": {
    "CheckpointConfiguration": {
      "ConfigurationType": "DEFAULT"|"CUSTOM",
      "CheckpointingEnabled": true|false,
      "CheckpointInterval": long,
      "MinPauseBetweenCheckpoints": long
    },
    "MonitoringConfiguration": {
      "ConfigurationType": "DEFAULT"|"CUSTOM",
      "MetricsLevel": "APPLICATION"|"TASK"|"OPERATOR"|"PARALLELISM",
      "LogLevel": "INFO"|"WARN"|"ERROR"|"DEBUG"
    },
    "ParallelismConfiguration": {
      "ConfigurationType": "DEFAULT"|"CUSTOM",
      "Parallelism": integer,
      "ParallelismPerKPU": integer,
      "AutoScalingEnabled": true|false
    }
  },
  "EnvironmentProperties": {
    "PropertyGroups": [
      {
        "PropertyGroupId": "string",
        "PropertyMap": {"string": "string"
          ...}
      }
      ...
    ]
  },
  "ApplicationCodeConfiguration": {
    "CodeContent": {
      "TextContent": "string",
      "ZipFileContent": blob,
      "S3ContentLocation": {
        "BucketARN": "string",
        "FileKey": "string",
        "ObjectVersion": "string"
      }
    },
    "CodeContentType": "PLAINTEXT"|"ZIPFILE"
  },
  "ApplicationSnapshotConfiguration": {
    "SnapshotsEnabled": true|false
  },
  "ApplicationSystemRollbackConfiguration": {
    "RollbackEnabled": true|false
  },
  "VpcConfigurations": [
    {
      "SubnetIds": ["string", ...],
      "SecurityGroupIds": ["string", ...]
    }
    ...
  ],
  "ZeppelinApplicationConfiguration": {
    "MonitoringConfiguration": {
      "LogLevel": "INFO"|"WARN"|"ERROR"|"DEBUG"
    },
    "CatalogConfiguration": {
      "GlueDataCatalogConfiguration": {
        "DatabaseARN": "string"
      }
    },
    "DeployAsApplicationConfiguration": {
      "S3ContentLocation": {
        "BucketARN": "string",
        "BasePath": "string"
      }
    },
    "CustomArtifactsConfiguration": [
      {
        "ArtifactType": "UDF"|"DEPENDENCY_JAR",
        "S3ContentLocation": {
          "BucketARN": "string",
          "FileKey": "string",
          "ObjectVersion": "string"
        },
        "MavenReference": {
          "GroupId": "string",
          "ArtifactId": "string",
          "Version": "string"
        }
      }
      ...
    ]
  }
}

--cloud-watch-logging-options (список)

Используйте этот параметр для настройки потока журнала Amazon CloudWatch, чтобы отслеживать ошибки конфигурации приложения.

(структура)

Предоставляет описание параметров ведения журнала Amazon CloudWatch, включая Amazon Resource Name (ARN) потока журнала.

LogStreamARN -> (строка)

ARN потока журнала CloudWatch для получения сообщений приложения.

Сокращенный синтаксис:

LogStreamARN=string ...

Синтаксис JSON:

[
  {
    "LogStreamARN": "string"
  }
  ...
]

--tags (список)

Список одного или нескольких тегов, которые необходимо назначить приложению. Тег — это пара «ключ-значение», которая идентифицирует приложение. Обратите внимание, что максимальное количество тегов приложения включает системные теги. Максимальное количество пользовательских тегов приложения составляет 50. Дополнительную информацию см. в разделе Использование тегов.

(структура)

Пара «ключ-значение» (значение необязательно), которую вы можете определить и назначить ресурсам Amazon. Если вы указываете тег, который уже существует, значение тега заменяется значением, указанным в запросе. Обратите внимание, что максимальное количество тегов приложения включает системные теги. Максимальное количество пользовательских тегов приложения составляет 50. Дополнительную информацию см. в разделе Использование тегов.

Ключ -> (строка)

Ключ тега «ключ-значение».

Значение -> (строка)

Значение тега «ключ-значение». Значение необязательно.

Сокращенная синтаксическая запись:

Key=string,Value=string ...

Синтаксис JSON:

[
  {
    "Key": "string",
    "Value": "string"
  }
  ...
]

--application-mode (строка)

Используйте режим STREAMING для создания управляемого сервиса приложения Apache Flink. Чтобы создать управляемый сервис блокнота Apache Flink Studio, используйте режим INTERACTIVE.

Возможные значения:

STREAMING
INTERACTIVE

--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
text
таблица
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 -> (структура)

В ответ на ваш запрос CreateApplication, Управляемая служба Apache Flink возвращает ответ с подробностями созданного приложения.

ApplicationARN -> (строка)

Уникальный идентификатор (ARN) приложения.

ApplicationDescription -> (строка)

Описание приложения.

ApplicationName -> (строка)

Имя приложения.

RuntimeEnvironment -> (строка)

Вычислительная среда приложения.

ServiceExecutionRole -> (строка)

Указывает роль IAM, которую приложение использует для доступа к внешним ресурсам.

ApplicationStatus -> (строка)

Статус приложения.

ApplicationVersionId -> (целое число)

Предоставляет текущую версию приложения. Управляемая служба Apache Flink обновляет ApplicationVersionId каждый раз при обновлении приложения.

CreateTimestamp -> (метка времени)

Текущая метка времени создания приложения.

LastUpdateTimestamp -> (метка времени)

Текущая метка времени последнего обновления приложения.

ApplicationConfigurationDescription -> (структура)

Описывает подробности кода приложения и параметров запуска для приложения Managed Service for Apache Flink.

SqlApplicationConfigurationDescription -> (структура)

Подробности о входных данных, выходных данных и источниках референсных данных для приложения Kinesis Data Analytics на основе SQL.

InputDescriptions -> (список)

Массив объектов InputDescription, описывающих входные потоки, используемые приложением.

(структура)

Описывает конфигурацию входных данных приложения для приложения Kinesis Data Analytics на основе SQL.

InputId -> (строка)

Идентификатор входных данных, связанный с входными данными приложения. Это идентификатор, который Kinesis Data Analytics присваивает каждой конфигурации входных данных, которую вы добавляете в своё приложение.

NamePrefix -> (строка)

Префикс имени внутри приложения.

InAppStreamNames -> (список)

Возвращает имена потоков внутри приложения, которые сопоставлены с источником потока.

(строка)

InputProcessingConfigurationDescription -> (структура)

Описание предобработчика, который выполняется над записями в этом входе перед запуском кода приложения.

InputLambdaProcessorDescription -> (структура)

Предоставляет конфигурационную информацию об ассоциированном InputLambdaProcessorDescription

ResourceARN -> (строка)

ARN функции Amazon Lambda, используемой для предобработки записей в потоке.

Примечание

Для указания более ранней версии функции Lambda, чем последняя, включите версию функции Lambda в ARN функции Lambda. Дополнительную информацию о Lambda ARN см. в примере ARN: Amazon Lambda

RoleARN -> (строка)

ARN роли IAM, используемой для доступа к функции Amazon Lambda.

Примечание

Предоставлено для обратной совместимости. Приложения, созданные с текущей версией API, имеют роль выполнения сервиса на уровне приложения, а не на уровне ресурса.

KinesisStreamsInputDescription -> (структура)

Если поток данных Kinesis настроен в качестве источника потока, предоставляет ARN потока данных Kinesis.

ResourceARN -> (строка)

Amazon Resource Name (ARN) потока данных Kinesis.

RoleARN -> (строка)

ARN роли IAM, которую Kinesis Data Analytics может использовать для доступа к потоку.

Примечание

KinesisFirehoseInputDescription -> (структура)

Если поток доставки Kinesis Data Firehose настроен в качестве источника потока, предоставляет ARN потока доставки.

ResourceARN -> (строка)

Amazon Resource Name (ARN) потока доставки.

RoleARN -> (строка)

ARN роли IAM, которую Kinesis Data Analytics использует для доступа к потоку.

Примечание

InputSchema -> (структура)

Описывает формат данных в источнике потока и то, как каждый элемент данных отображается на соответствующие столбцы в потоке приложения.

RecordFormat -> (структура)

Указывает формат записей в источнике потока.

RecordFormatType -> (строка)

Тип формата записи.

MappingParameters -> (структура)

При настройке входных данных приложения при создании или обновлении приложения, предоставляет дополнительную информацию о сопоставлении, специфичную для формата записи (такого как JSON, CSV или записи, разделяемые разделителем) в источнике потока.

JSONMappingParameters -> (структура)

Предоставляет дополнительную информацию о сопоставлении, когда JSON является форматом записи в источнике потока.

RecordRowPath -> (строка)

Путь к родительскому элементу верхнего уровня, содержащему записи.

CSVMappingParameters -> (структура)

Предоставляет дополнительную информацию о сопоставлении, когда формат записи использует разделители (например, CSV).

RecordRowDelimiter -> (строка)

Разделитель строк. Например, в формате CSV ‘n’ является типичным разделителем строк.

RecordColumnDelimiter -> (строка)

Разделитель столбцов. Например, в формате CSV запятая (“,”) является типичным разделителем столбцов.

RecordEncoding -> (строка)

Указывает кодировку записей в источнике потока. Например, UTF-8.

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 -> (строка)

Amazon Resource Name (ARN) потока данных Kinesis.

RoleARN -> (строка)

ARN роли IAM, которую Kinesis Data Analytics может использовать для доступа к потоку.

Примечание

KinesisFirehoseOutputDescription -> (структура)

Описывает поток доставки Kinesis Data Firehose, настроенный как место назначения, куда записывается вывод.

ResourceARN -> (строка)

Amazon Resource Name (ARN) потока доставки.

RoleARN -> (строка)

ARN роли IAM, которую Kinesis Data Analytics может использовать для доступа к потоку.

Примечание

LambdaOutputDescription -> (структура)

Описывает функцию Lambda, настроенную как место назначения, куда записывается вывод.

ResourceARN -> (строка)

Amazon Resource Name (ARN) целевой функции Lambda.

RoleARN -> (строка)

ARN роли IAM, которую Kinesis Data Analytics может использовать для записи в целевую функцию.

Примечание

DestinationSchema -> (структура)

Формат данных, используемый для записи данных в место назначения.

RecordFormatType -> (строка)

Указывает формат записей в выходном потоке.

ReferenceDataSourceDescriptions -> (список)

Массив объектов ReferenceDataSourceDescription, описывающих источники справочных данных, используемые приложением.

(структура)

Для приложения Kinesis Data Analytics на основе SQL описывает источник справочных данных, настроенный для приложения.

ReferenceId -> (строка)

Идентификатор источника справочных данных. Это идентификатор, который Kinesis Data Analytics присваивает при добавлении источника справочных данных к вашему приложению с помощью операции CreateApplication или UpdateApplication.

TableName -> (строка)

Имя таблицы в приложении, созданное конкретной конфигурацией источника справочных данных.

S3ReferenceDataSourceDescription -> (структура)

Предоставляет имя ведра Amazon S3 и имя ключа объекта, содержащего справочные данные.

BucketARN -> (строка)

Идентификатор ресурса Amazon S3 (ARN) ведра.

FileKey -> (строка)

Имя ключа объекта Amazon S3.

ReferenceRoleARN -> (строка)

ARN роли IAM, которую Kinesis Data Analytics может принять, чтобы прочитать объект Amazon S3 от вашего имени и заполнить таблицу справочных данных в приложении.

Примечание

Предоставлено для обратной совместимости. Приложения, созданные с использованием текущей версии API, имеют роль выполнения службы на уровне приложения, а не роль на уровне ресурса.

ReferenceSchema -> (структура)

Описывает формат данных в источнике потоковой передачи и то, как каждый элемент данных сопоставляется с соответствующими столбцами, созданными в потоке приложения.

RecordFormat -> (структура)

Определяет формат записей в источнике потоковой передачи.

RecordFormatType -> (строка)

Тип формата записей.

MappingParameters -> (структура)

При настройке входных данных приложения во время создания или обновления приложения предоставляет дополнительную информацию о сопоставлении, специфичную для формата записей (таких как JSON, CSV или поля записей, разделяемые каким-либо разделителем) в источнике потоковой передачи.

JSONMappingParameters -> (структура)

Предоставляет дополнительную информацию о сопоставлении, когда формат записей в источнике потоковой передачи — JSON.

RecordRowPath -> (строка)

Путь к родительскому элементу верхнего уровня, содержащему записи.

CSVMappingParameters -> (структура)

RecordRowDelimiter -> (строка)

Разделитель строк. Например, в формате CSV типичным разделителем строк является ‘n’.

RecordColumnDelimiter -> (строка)

Разделитель столбцов. Например, в формате CSV типичным разделителем столбцов является запятая (",").

RecordEncoding -> (строка)

Указывает кодировку записей в источнике потоковой передачи. Например, UTF-8.

RecordColumns -> (список)

Список объектов RecordColumn.

(структура)

Для приложения Kinesis Data Analytics на основе SQL описывает сопоставление каждого элемента данных в источнике потоковой передачи с соответствующим столбцом в потоке приложения.

Также используется для описания формата источника справочных данных.

Name -> (строка)

Имя столбца, созданного в потоке входных данных или таблице справочных данных приложения.

Mapping -> (строка)

Ссылка на элемент данных в входных данных потоковой передачи или источнике справочных данных.

SqlType -> (строка)

Тип столбца, созданного в потоке входных данных или таблице справочных данных приложения.

ApplicationCodeConfigurationDescription -> (структура)

Подробности о коде приложения для приложения Managed Service для Apache Flink.

CodeContentType -> (строка)

Указывает, находится ли содержимое кода в текстовом или zip-формате.

CodeContentDescription -> (структура)

Описывает подробности о расположении и формате кода приложения.

TextContent -> (строка)

Код в текстовом формате

CodeMD5 -> (строка)

Контрольная сумма, которая может использоваться для проверки кода в формате zip.

CodeSize -> (длинное целое)

Размер кода приложения в байтах. Может использоваться для проверки кода в формате zip.

S3ApplicationCodeLocationDescription -> (структура)

Идентификатор ресурса Amazon S3 (ARN) ведра S3, ключ файла и версия объекта кода приложения, хранящегося в Amazon S3.

BucketARN -> (строка)

Идентификатор ресурса Amazon S3 (ARN) ведра S3, содержащего код приложения.

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 for Apache Flink.

CheckpointConfigurationDescription -> (структура)

Описывает конфигурацию сохранения контрольных точек приложения. Сохранение контрольных точек — это процесс сохранения состояния приложения для обеспечения отказоустойчивости.

ConfigurationType -> (строка)

Описывает, использует ли приложение стандартное поведение сохранения контрольных точек в Managed Service for Apache Flink.

Примечание

Если это значение установлено в DEFAULT, приложение будет использовать следующие значения, даже если они установлены в другие значения с помощью API или кода приложения:

CheckpointingEnabled: true
CheckpointInterval: 60000
MinPauseBetweenCheckpoints: 5000

CheckpointingEnabled -> (булево)

Описывает, включено ли сохранение контрольных точек для приложения Managed Service for 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 -> (строка)

Описывает, использовать ли стандартную конфигурацию ведения журнала CloudWatch для приложения.

MetricsLevel -> (строка)

Описывает точность журналов CloudWatch Logs для приложения.

LogLevel -> (строка)

Описывает подробность журналов CloudWatch Logs для приложения.

ParallelismConfigurationDescription -> (структура)

Описывает параметры выполнения несколькими задачами одновременно для приложения.

ConfigurationType -> (строка)

Описывает, использует ли приложение стандартный уровень параллелизма для Managed Service for Apache Flink.

Parallelism -> (целое число)

Описывает начальное количество параллельных задач, которые может выполнять приложение Managed Service for Apache Flink. Если AutoScalingEnabled установлено в True, Managed Service for Apache Flink может увеличить значение CurrentParallelism в ответ на нагрузку приложения. Сервис может увеличить CurrentParallelism до максимального уровня параллелизма, который составляет ParalellismPerKPU кратное максимальному числу KPUs для приложения. Максимальное число KPUs для приложения по умолчанию составляет 32 и может быть увеличено путем запроса увеличения предела. Если нагрузка приложения снижается, сервис может уменьшить значение CurrentParallelism до значения по умолчанию Parallelism.

ParallelismPerKPU -> (целое число)

Описывает количество параллельных задач, которые может выполнять приложение Managed Service for Apache Flink на каждую единицу Kinesis Processing Unit (KPU), используемую приложением.

CurrentParallelism -> (целое число)

Описывает текущее количество параллельных задач, которые может выполнять приложение Managed Service for Apache Flink. Если AutoScalingEnabled установлено в True, Managed Service for Apache Flink может увеличить это значение в ответ на нагрузку приложения. Сервис может увеличить это значение до максимального уровня параллелизма, который составляет ParalellismPerKPU кратное максимальному числу KPUs для приложения. Максимальное число KPUs для приложения по умолчанию составляет 32 и может быть увеличено путем запроса увеличения предела. Если нагрузка приложения снижается, сервис может уменьшить значение CurrentParallelism до значения по умолчанию Parallelism.

AutoScalingEnabled -> (булево)

Описывает, может ли Managed Service for Apache Flink увеличивать параллелизм приложения в ответ на увеличение пропускной способности.

JobPlanDescription -> (строка)

План задания для приложения. Для получения дополнительной информации о плане задания, см. разделы «Работы и планирование» в документации Apache Flink. Чтобы получить план задания для приложения, используйте параметр DescribeApplicationRequest$IncludeAdditionalDetails операции DescribeApplication.

EnvironmentPropertyDescriptions -> (структура)

Описывает свойства выполнения для приложения Managed Service for Apache Flink.

PropertyGroupDescriptions -> (список)

Описывает группы свойств выполнения.

(структура)

Пара пары «ключ-значение» свойств, переданных приложению.

PropertyGroupId -> (строка)

Описывает ключ пары «ключ-значение» свойства выполнения приложения.

PropertyMap -> (карта)

Описывает значение пары «ключ-значение» свойства выполнения приложения.

key -> (строка)

value -> (строка)

ApplicationSnapshotConfigurationDescription -> (структура)

Описывает, включены ли снимки для приложения Managed Service for Apache Flink.

SnapshotsEnabled -> (булево)

Описывает, включены ли снимки для приложения Managed Service for Apache Flink.

ApplicationSystemRollbackConfigurationDescription -> (структура)

Описывает конфигурацию отката системы для приложения Managed Service for Apache Flink.

RollbackEnabled -> (булево)

Описывает, включены ли откаты системы для приложения Managed Service for Apache Flink

VpcConfigurationDescriptions -> (список)

Массив описаний конфигураций VPC, доступных для приложения.

(структура)

Описывает параметры VPC, используемого приложением.

VpcConfigurationId -> (строка)

Идентификатор конфигурации VPC.

VpcId -> (строка)

Идентификатор связанной VPC.

SubnetIds -> (список)

Массив идентификаторов подсетей, используемых конфигурацией VPC.

(строка)

SecurityGroupIds -> (список)

Массив идентификаторов групп безопасности, используемых конфигурацией VPC.

(строка)

ZeppelinApplicationConfigurationDescription -> (структура)

Параметры конфигурации для блокнота Managed Service for Apache Flink Studio.

MonitoringConfigurationDescription -> (структура)

Конфигурация мониторинга для блокнота Managed Service for Apache Flink Studio.

LogLevel -> (строка)

Описывает подробность журналов CloudWatch Logs для приложения.

CatalogConfigurationDescription -> (структура)

Amazon Glue Data Catalog, связанный с блокнотом Managed Service for Apache Flink Studio.

GlueDataCatalogConfigurationDescription -> (структура)

Параметры конфигурации для базы данных Amazon Glue по умолчанию. Вы используете эту базу данных для запросов SQL, которые вы пишете в блокноте Managed Service for Apache Flink Studio.

DatabaseARN -> (строка)

Amazon Resource Name (ARN) базы данных.

DeployAsApplicationConfigurationDescription -> (структура)

Параметры, необходимые для развертывания блокнота Managed Service for Apache Flink Studio как приложения с постоянным состоянием.

S3ContentLocationDescription -> (структура)

Расположение, содержащее данные, необходимые для указания приложения Amazon Data Analytics.

BucketARN -> (строка)

Amazon Resource Name (ARN) корзины S3.

BasePath -> (строка)

Базовая директория корзины S3.

CustomArtifactsConfigurationDescription -> (список)

Пользовательские артефакты — это зависимые JAR-файлы и пользовательские функции (UDF).

(структура)

Определяет зависимый JAR-файл или JAR-файл пользовательских функций.

ArtifactType -> (строка)

UDF обозначает пользовательские функции. Этот тип артефакта должен находиться в корзине S3. DEPENDENCY_JAR может находиться как в Maven, так и в корзине S3.

S3ContentLocationDescription -> (структура)

Для приложения Managed Service for Apache Flink предоставляет описание объекта Amazon S3, включая Amazon Resource Name (ARN) корзины S3, имя объекта Amazon S3, содержащего данные, и номер версии объекта Amazon S3, содержащего данные.

BucketARN -> (строка)

Amazon Resource Name (ARN) корзины S3, содержащей код приложения.

FileKey -> (строка)

Ключ файла для объекта, содержащего код приложения.

ObjectVersion -> (строка)

Версия объекта, содержащего код приложения.

MavenReferenceDescription -> (структура)

Параметры, необходимые для указания зависимости Maven.

GroupId -> (строка)

Идентификатор группы Maven-ссылки.

ArtifactId -> (строка)

Идентификатор артефакта Maven-ссылки.

Version -> (строка)

Версия Maven-ссылки.

CloudWatchLoggingOptionDescriptions -> (список)

Описывает параметры ведения журналов Amazon CloudWatch для приложения.

(структура)

Описывает параметр ведения журнала Amazon CloudWatch.

CloudWatchLoggingOptionId -> (строка)

Идентификатор описания параметра ведения журнала CloudWatch.

LogStreamARN -> (строка)

Amazon Resource Name (ARN) журнала CloudWatch для получения сообщений приложения.

RoleARN -> (строка)

IAM ARN роли, используемой для отправки сообщений приложения.

Примечание

Предоставлено для обратной совместимости. Приложения, созданные с использованием текущей версии API, имеют роль выполнения сервиса на уровне приложения, а не роль на уровне ресурса.

ApplicationMaintenanceConfigurationDescription -> (структура)

Подробности конфигурации технического обслуживания для приложения.

ApplicationMaintenanceWindowStartTime -> (строка)

Время начала окна технического обслуживания.

ApplicationMaintenanceWindowEndTime -> (строка)

Время окончания окна технического обслуживания.

ApplicationVersionUpdatedFrom -> (длинное целое)

Предыдущая версия приложения перед последним обновлением. RollbackApplication восстанавливает приложение до этой версии.

ApplicationVersionRolledBackFrom -> (длинное целое)

Если вы вернули приложение с помощью RollbackApplication, версия приложения, когда RollbackApplication был вызван.

ApplicationVersionCreateTimestamp -> (timestamp)

Текущая метка времени создания версии приложения.

ConditionalToken -> (string)

Значение, используемое для реализации сильной конкурентности при обновлении приложения.

ApplicationVersionRolledBackTo -> (long)

Версия, к которой вы хотите откатить приложение.

ApplicationMode -> (string)

Для создания Управляемой службы для Apache Flink Studio ноутбука, вы должны установить режим в INTERACTIVE. Однако для Управляемой службы для приложения Apache Flink этот режим является необязательным.