PutDynamoDB 2025.10.9.21

Bundle

org.apache.nifi | nifi-aws-nar

Description

Puts a document from DynamoDB based on hash and range key. The table can have either hash and range or hash key alone. Currently the keys supported are string and number and value can be json document. In case of hash and range keys both key are required for the operation. The FlowFile content must be JSON. FlowFile content is mapped to the specified Json Document attribute in the DynamoDB item.

Tags

AWS, Amazon, DynamoDB, Insert, Put

Input Requirement

REQUIRED

Supports Sensitive Dynamic Properties

false

Properties

PropertyDescription
AWS Credentials Provider serviceThe Controller Service that is used to obtain AWS credentials provider
Batch items for each request (between 1 and 50)The items to be retrieved in one batch
Character set of documentCharacter set of data in the document
Communications Timeout
Endpoint Override URLEndpoint URL to use instead of the AWS default including scheme, host, port, and path. The AWS libraries select an endpoint URL based on the AWS region, but this property overrides the selected endpoint URL, allowing use with other S3-compatible endpoints.
Hash Key NameThe hash key name of the item
Hash Key ValueThe hash key value of the item
Hash Key Value TypeThe hash key value type of the item
Json Document attributeThe Json document to be retrieved from the dynamodb item ( ‘s’ type in the schema)
Range Key NameThe range key name of the item
Range Key Value
Range Key Value TypeThe range key value type of the item
Region
SSL Context ServiceSpecifies an optional SSL Context Service that, if provided, will be used to create connections
Table NameThe DynamoDB table name
proxy-configuration-serviceSpecifies the Proxy Configuration Controller Service to proxy network requests.

Relationships

NameDescription
failureFlowFiles are routed to failure relationship
successFlowFiles are routed to success relationship
unprocessedFlowFiles are routed to unprocessed relationship when DynamoDB is not able to process all the items in the request. Typical reasons are insufficient table throughput capacity and exceeding the maximum bytes per request. Unprocessed FlowFiles can be retried with a new request.

Writes attributes

NameDescription
dynamodb.key.error.unprocessedDynamoDB unprocessed keys
dynmodb.range.key.value.errorDynamoDB range key error
dynamodb.key.error.not.foundDynamoDB key not found
dynamodb.error.exception.messageDynamoDB exception message
dynamodb.error.codeDynamoDB error code
dynamodb.error.messageDynamoDB error message
dynamodb.error.serviceDynamoDB error service
dynamodb.error.retryableDynamoDB error is retryable
dynamodb.error.request.idDynamoDB error request id
dynamodb.error.status.codeDynamoDB error status code
dynamodb.item.io.errorIO exception message on creating item

See also