PutDynamoDBRecord
Описание
Вставляет элементы в DynamoDB на основе данных, ориентированных на записи. Поля записей сопоставляются с полями элементов DynamoDB, включая ключи разделов и сортировки, если они заданы. В зависимости от количества записей процессор может выполнить вставку в несколько этапов, чтобы обойти ограничение DynamoDB на пакетную запись. Это может привести к частично обработанным FlowFile, в этом случае FlowFile будет перенаправлен в связь "unprocessed" с необходимыми атрибутами для повторной попытки без дублирования уже выполненных вставок.
Теги
Amazon, DynamoDB, AWS, Put, Insert, Record
Свойства
Название | Описание |
---|---|
Table Name | Название таблицы DynamoDB Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
Region | No description provided. |
AWS Credentials Provider Service | Служба контроллера, которая используется для получения поставщика учетных данных AWS. |
Record Reader | Указывает службу контроллера, используемую для анализа входящих данных и определения их схемы. |
Partition Key Strategy | Определяет стратегию, которую процессор использует для присвоения значения ключа раздела вставленным элементам. |
Partition Key Field | Defines 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 Timeout | No description provided. |
Endpoint Override URL | URL-адрес конечной точки, который будет использоваться вместо URL-адреса AWS по умолчанию, включая схему, хост, порт и путь. Библиотеки AWS выбирают URL-адрес конечной точки в зависимости от региона AWS, но это свойство переопределяет выбранный URL-адрес конечной точки, позволяя использовать другие конечные точки, совместимые с S3. Поддерживает язык выражений: true (будет оцениваться только с использованием переменных среды) |
Proxy Configuration Service | Specifies 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: Файлы потока направляются в отношение сбоя