Support Questions

Find answers, ask questions, and share your expertise

I am getting error on putDynamodb

Explorer

2022-03-30 06:12:42,697 ERROR [Timer-Driven Process Thread-10] o.a.n.p.aws.dynamodb.PutDynamoDB PutDynamoDB[id=d8f73587-017f-1000-2455-aaff9f514cba] Hash key value '' is required for flow file StandardFlowFileRecord[uuid=eaf5b5ae-86c1-44b1-a253-00d44fdbbbff,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1648526788099-3, container=default, section=3], offset=0, length=45235],offset=44777,name=472d9a5c-9b9e-4a2e-91ae-589fbf7a5bec,size=458]
2022

gizo_0-1648651018334.png

gizo_0-1648651956847.png

 

Any help will be much appreciated.

5 REPLIES 5

Master Collaborator

@gizo ,

 

Is "dynamodb.item.hash.key.value" a property of your flowfile?

Could you show a screenshot of the flowfile properties para with that property?

 

Cheers,

André

 

--
Was your question answered? Please take some time to click on "Accept as Solution" below this post.
If you find a reply useful, say thanks by clicking on the thumbs up button.

Explorer

This is what I have. 

gizo_0-1648732378840.png

sample json from the executesql after split json.

{
"CreatedBy" : "jdhjhehdhjdjs",
"CreatedDateTime" : "2021-10-20 12:05:42.0",
"LastModBy" : "dhjdjjwjsjds",
"LastModDateTime" : "2021-12-01 17:41:31.0",
"OwnerTeam" : null,
"OwnerType" : null,
"RecId" : "udhehdhhwgeueuhd73764hdhsh",
"CloudServiceTag" : null,
"SQLCores" : null
}

gizo_1-1648732554554.png

gizo_2-1648732577399.png

 

Master Collaborator

@gizo ,

 

The JSON you shared is the "content" of the flowfile. The flowfile also have "attributes" metadata. Could you please share a screenshot of that?

 

André

--
Was your question answered? Please take some time to click on "Accept as Solution" below this post.
If you find a reply useful, say thanks by clicking on the thumbs up button.

Explorer

see below

gizo_0-1648821734286.png

gizo_1-1648821802208.png

gizo_2-1648822172329.png

Attribute Values
 
RecId
udhehdhhwgeueuhd73764hdhsh
 
executesql.query.duration
32
 
executesql.query.executiontime
24
 
executesql.query.fetchtime
8
 
executesql.resultset.index
0
 
executesql.row.count
100
 
filename
9c344c33-599e-4dfd-9eda-2006f6df0de5
 
fragment.count
100
 
fragment.identifier
da135c88-697d-498f-a5e3-6a45f23eb44a
 
fragment.index
0
 
mime.type
application/json
 
path
./
 
segment.original.filename
9c344c33-599e-4dfd-9eda-2006f6df0de5
 
uuid
34d005dc-09c2-446c-b7aa-963b31e9769a

 

Master Collaborator

@gizo ,

 

In your processor you set "Ranger Key Value" to "${dynamodb.item.range.key.value}". This would reference to an attribute in your flowfile, but from the details you provided, there's no such attribute there. This may be the cause of the error.

 

You must ensure that the attribute exists in the flowfile so that you can reference it in the processor configuration.

 

Cheers,

André

 

--
Was your question answered? Please take some time to click on "Accept as Solution" below this post.
If you find a reply useful, say thanks by clicking on the thumbs up button.