update-event-source-mapping

Описание

Обновляет отображение источника событий. Вы можете изменить функцию, которую Lambda вызывает, или приостановить вызов и возобновить его позже с того же места.

Подробную информацию о настройке различных источников событий см. в следующих разделах.

• Потоки Amazon DynamoDB
• Amazon Kinesis
• Amazon SQS
• Amazon MQ и RabbitMQ
• Amazon MSK
• Apache Kafka
• Amazon DocumentDB

Следующие параметры обработки ошибок доступны только для источников событий DynamoDB и Kinesis:

• BisectBatchOnFunctionError – Если функция возвращает ошибку, разделите пакет на две части и повторите попытку.
• MaximumRecordAgeInSeconds – Отбрасывайте записи, которые старше указанного возраста. Значение по умолчанию — бесконечность (-1). При значении бесконечности (-1) не удавшиеся записи повторно обрабатываются до истечения срока действия записи.
• MaximumRetryAttempts – Отбрасывайте записи после указанного числа попыток. Значение по умолчанию — бесконечность (-1). При значении бесконечности (-1) не удавшиеся записи повторно обрабатываются до истечения срока действия записи.
• ParallelizationFactor – Одновременная обработка нескольких пакетов из каждого раздела.

Для источников потоков (DynamoDB, Kinesis, Amazon MSK и самонастраиваемый Apache Kafka) также доступен следующий параметр:

• DestinationConfig – Отправлять отброшенные записи в очередь Amazon SQS, тему Amazon SNS или ведро Amazon S3.

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

• Потоки Amazon DynamoDB
• Amazon Kinesis
• Amazon SQS
• Amazon MQ и RabbitMQ
• Amazon MSK
• Apache Kafka
• Amazon DocumentDB

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

Синтаксис

  update-event-source-mapping
--uuid <value>
[--function-name <value>]
[--enabled | --no-enabled]
[--batch-size <value>]
[--filter-criteria <value>]
[--maximum-batching-window-in-seconds <value>]
[--destination-config <value>]
[--maximum-record-age-in-seconds <value>]
[--bisect-batch-on-function-error | --no-bisect-batch-on-function-error]
[--maximum-retry-attempts <value>]
[--parallelization-factor <value>]
[--source-access-configurations <value>]
[--tumbling-window-in-seconds <value>]
[--function-response-types <value>]
[--scaling-config <value>]
[--document-db-event-source-config <value>]
[--kms-key-arn <value>]
[--metrics-config <value>]
[--provisioned-poller-config <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]

Параметры

--uuid (строка)

--function-name (строка)

--enabled | --no-enabled (логическое значение)

--batch-size (целое число)

--filter-criteria (структура)

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

Filters=[{Pattern=string},{Pattern=string}]

Синтаксис JSON:

{
  "Filters": [
    {
      "Pattern": "string"
    }
    ...
  ]
}

--maximum-batching-window-in-seconds (целое число)

--destination-config (структура)

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

OnSuccess={Destination=string},OnFailure={Destination=string}

Синтаксис JSON:

{
  "OnSuccess": {
    "Destination": "string"
  },
  "OnFailure": {
    "Destination": "string"
  }
}

--maximum-record-age-in-seconds (целое число)

--bisect-batch-on-function-error | --no-bisect-batch-on-function-error (логическое значение)

--maximum-retry-attempts (целое число)

--parallelization-factor (целое число)

--source-access-configurations (список)

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

Type=string,URI=string ...

Синтаксис JSON:

[
  {
    "Type": "BASIC_AUTH"|"VPC_SUBNET"|"VPC_SECURITY_GROUP"|"SASL_SCRAM_512_AUTH"|"SASL_SCRAM_256_AUTH"|"VIRTUAL_HOST"|"CLIENT_CERTIFICATE_TLS_AUTH"|"SERVER_ROOT_CA_CERTIFICATE",
    "URI": "string"
  }
  ...
]

--tumbling-window-in-seconds (целое число)

--function-response-types (список)

Синтаксис:

"string" "string" ...

Where valid values are:
  ReportBatchItemFailures

--scaling-config (структура)

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

MaximumConcurrency=integer

Синтаксис JSON:

{
  "MaximumConcurrency": integer
}

--document-db-event-source-config (структура)

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

DatabaseName=string,CollectionName=string,FullDocument=string

Синтаксис JSON:

{
  "DatabaseName": "string",
  "CollectionName": "string",
  "FullDocument": "UpdateLookup"|"Default"
}

--kms-key-arn (строка)

--metrics-config (структура)

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

Metrics=string,string

Синтаксис JSON:

{
  "Metrics": ["EventCount", ...]
}

--provisioned-poller-config (структура)

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

MinimumPollers=integer,MaximumPollers=integer

Синтаксис JSON:

{
  "MinimumPollers": integer,
  "MaximumPollers": integer
}

--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 (логическое значение)

Автоматически запросить параметры ввода командной строки.

--no-cli-auto-prompt (логическое значение)

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

Примеры

Для обновления сопоставления между источником событий и функцией AWS Lambda

Следующий update-event-source-mapping пример обновляет размер пакета до 8 в указанном сопоставлении.

aws lambda update-event-source-mapping \
    --uuid  "a1b2c3d4-5678-90ab-cdef-11111EXAMPLE" \
    --batch-size 8

Вывод:

{
    "UUID": "a1b2c3d4-5678-90ab-cdef-11111EXAMPLE",
    "StateTransitionReason": "USER_INITIATED",
    "LastModified": 1569284520.333,
    "BatchSize": 8,
    "State": "Updating",
    "FunctionArn": "arn:aws:lambda:us-west-2:123456789012:function:my-function",
    "EventSourceArn": "arn:aws:sqs:us-west-2:123456789012:mySQSqueue"
}

Дополнительную информацию см. в разделе AWS Lambda Event Source Mapping в руководстве разработчика AWS Lambda.

Вывод

UUID -> (строка)

StartingPosition -> (строка)

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

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

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

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

EventSourceArn -> (строка)

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

FunctionArn -> (строка)

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

LastProcessingResult -> (строка)

State -> (строка)

StateTransitionReason -> (строка)

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

Topics -> (список)

Queues -> (список)

SourceAccessConfigurations -> (список)

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

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

BisectBatchOnFunctionError -> (булево)

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

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

FunctionResponseTypes -> (список)

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

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

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

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

KMSKeyArn -> (string)

FilterCriteriaError -> (structure)

EventSourceMappingArn -> (string)

MetricsConfig -> (structure)

ProvisionedPollerConfig -> (structure)