Support Questions

Find answers, ask questions, and share your expertise

Attributes to flow file

avatar
Contributor

I have a complex flow where I created 3 attributes, [name, date, json_content] extracted from other flow file data that need to go into a database. How can I take these 3 attributes convert them to a new flow file with those columns? The schema I will use has those names. 

Schema:
{
"type": "record",
"name": "mytable",
"fields": [
{"name": "name","type": [ "string" ]},
{"name": "date","type": "type" : [ "null", { "type" : "long", "logicalType" : "timestamp-millis" } ], "default" : null }
},
{"name": "json_content","type": [ "string" ]

}]
}

1 ACCEPTED SOLUTION

avatar
Contributor

Tried to delete this as noone seems to answer here.

But if someone has a similiar issue, just UpdateAttribute on attributes you want to create a new flowfile and then pass them to AttributesToJSON processor. 

View solution in original post

1 REPLY 1

avatar
Contributor

Tried to delete this as noone seems to answer here.

But if someone has a similiar issue, just UpdateAttribute on attributes you want to create a new flowfile and then pass them to AttributesToJSON processor.