Skip to main content

PutDynamoDBRecord

Описание

Вставляет элементы в DynamoDB на основе данных, ориентированных на записи. Поля записей сопоставляются с полями элементов DynamoDB, включая ключи разделов и сортировки, если они заданы. В зависимости от количества записей процессор может выполнить вставку в несколько этапов, чтобы обойти ограничение DynamoDB на пакетную запись. Это может привести к частично обработанным FlowFile, в этом случае FlowFile будет перенаправлен в связь "unprocessed" с необходимыми атрибутами для повторной попытки без дублирования уже выполненных вставок.

Теги

Amazon, DynamoDB, AWS, Put, Insert, Record

Свойства

НазваниеОписание
Table NameНазвание таблицы DynamoDB Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды)
RegionNo description provided.
AWS Credentials Provider ServiceСлужба контроллера, которая используется для получения поставщика учетных данных AWS.
Record ReaderУказывает службу контроллера, используемую для анализа входящих данных и определения их схемы.
Partition Key StrategyОпределяет стратегию, которую процессор использует для присвоения значения ключа раздела вставленным элементам.
Partition Key FieldDefines the name of the partition key field in the DynamoDB table. Partition key is also known as hash key. Depending on the "Partition Key Strategy" the field value might come from the incoming Record or a generated one. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды)
Partition Key AttributeУказывает атрибут FlowFile, который будет использоваться в качестве значения ключа раздела при использовании стратегии «Разделение по атрибуту». Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды)This Property is only considered if the [Partition Key Strategy] Property has a value of "Partition By Attribute".
Sort Key StrategyОпределяет стратегию, которую процессор использует для присвоения ключа сортировки вставленным элементам.
Sort Key FieldОпределяет имя поля ключа сортировки в таблице DynamoDB. Ключ сортировки также известен как ключ диапазона. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды)This Property is only considered if the [Sort Key Strategy] Property is set to one of the following values: [Sort By Field], [Generate Sequence]
Communications TimeoutNo description provided.
Endpoint Override URLURL-адрес конечной точки, который будет использоваться вместо URL-адреса AWS по умолчанию, включая схему, хост, порт и путь. Библиотеки AWS выбирают URL-адрес конечной точки в зависимости от региона AWS, но это свойство переопределяет выбранный URL-адрес конечной точки, позволяя использовать другие конечные точки, совместимые с S3. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды)
Proxy Configuration ServiceSpecifies the Proxy Configuration Controller Service to proxy network requests. If set, it supersedes proxy settings configured per component.
SSL Context ServiceУказывает необязательный контекстный сервис SSL, который, если он указан, будет использоваться для создания соединений

Взаимосвязи

  • unprocessed: Файлы потока направляются в необработанную связь, когда DynamoDB не может обработать все элементы запроса. Типичными причинами являются недостаточная пропускная способность таблицы и превышение максимального количества байт на запрос. Необработанные файлы FlowFiles можно отправить повторно с помощью нового запроса.
  • success: Файлы потока направляются в отношение успеха
  • failure: Файлы потока направляются в отношение сбоя