PutDynamoDB 2.3.0¶
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.
INPUT REQUIREMENT¶
REQUIRED
Supports Sensitive Dynamic Properties¶
false
PROPERTIES¶
Property |
Description |
---|---|
AWS Credentials Provider service |
The 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 document |
Character set of data in the document |
Communications Timeout |
|
Endpoint Override URL |
Endpoint 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 Name |
The hash key name of the item |
Hash Key Value |
The hash key value of the item |
Hash Key Value Type |
The hash key value type of the item |
Json Document attribute |
The Json document to be retrieved from the dynamodb item (‘s’ type in the schema) |
Range Key Name |
The range key name of the item |
Range Key Value |
|
Range Key Value Type |
The range key value type of the item |
Region |
|
SSL Context Service |
Specifies an optional SSL Context Service that, if provided, will be used to create connections |
Table Name |
The DynamoDB table name |
proxy-configuration-service |
Specifies the Proxy Configuration Controller Service to proxy network requests. Supported proxies: HTTP + AuthN |
RELATIONSHIPS¶
NAME |
DESCRIPTION |
---|---|
failure |
FlowFiles are routed to failure relationship |
unprocessed |
FlowFiles 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. |
success |
FlowFiles are routed to success relationship |
WRITES ATTRIBUTES¶
NAME |
DESCRIPTION |
---|---|
dynamodb.key.error.unprocessed |
DynamoDB unprocessed keys |
dynmodb.range.key.value.error |
DynamoDB range key error |
dynamodb.key.error.not.found |
DynamoDB key not found |
dynamodb.error.exception.message |
DynamoDB exception message |
dynamodb.error.code |
DynamoDB error code |
dynamodb.error.message |
DynamoDB error message |
dynamodb.error.service |
DynamoDB error service |
dynamodb.error.retryable |
DynamoDB error is retryable |
dynamodb.error.request.id |
DynamoDB error request id |
dynamodb.error.status.code |
DynamoDB error status code |
dynamodb.item.io.error |
IO exception message on creating item |