Created on
06-05-2019
06:54 PM
- last edited on
10-01-2019
09:41 AM
by
VidyaSargur
Hello, Everyone!
I have been trying to use the PutDynamoDB processor, and I almost there. I'm able to run the ExecuteSQLRecord to get my data and store in a JSON file. The data is flowing, but I'm getting the following error in the log:
PutDynamoDB[id=28e4e8cf-016b-1000-a35c-276514f81580] Hash key value '' is required for flow file StandardFlowFileRecord[uuid=0ce692ff-d784-4882-a565-f5425479d316,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1559758360111-4, container=default, section=4], offset=0, length=275868738],offset=0,name=0ce692ff-d784-4882-a565-f5425479d316.json,size=275868738]
I understand that, is looking for the Hash Key Value, but I not sure how do I pass it. In the PutDynamoDB properties tab, NiFi sets
${dynamodb.item.hash.key.value}
as default value. But looks like this isn't the right way to do it.
Can I get some guidance on this?
My workflow:
The JSON I'm trying to put in DynamoDB looks like this:
Any help will be appreciated
Thanks!
Created 10-01-2019 09:27 AM
Up!
Created 03-24-2021 05:30 PM
@peadalmeidaI believe if can use this same solution for your case.