Hi,
I need to be able to make a POST call to an API and the body should look like
this :
{
"location" : "355669",
"countryCode" : "NL",
"identificationNumber" : "NL 672760327",
"externalId" : "KTSPRED_01_817997491",
"dateTime" : "2019-11-08T04:33:41.000Z",
"value" : "GEMIDDELD_RISICO",
"type" : "ketosis_prediction",
"additionalInformation" : "{
"calvingDate": "2018-10-01",
"parity": "3",
"create_date": "2019-11-08T04:33:41.000Z "
}"
}
I tried the following AVRO definition for serialisation (starting from a csv
file) :
{
"type" : "record",
"name" : "person",
"namespace" : "nifi",
"fields" : [{"name" : "location" ,
"type" : "int"},
{"name" : "country" ,
"type" : "string"},
{"name" : "animal_number" ,
"type" : "string"},
{"name" : "alert_id" ,
"type" : "string"},
{"name" : "alert_date" ,
"type" : "string"},
{"name" : "type_of_alert" ,
"type" : "string"},
{"name" : "alert_name" ,
"type" : "string"},
{"name" : "additionalInformation",
"type" : {
"type" : "record",
"name" : "test",
"fields" : [
{"name" : "calving_date",
"type" : "string"},
{"name" : "parity",
"type" : "string"},
{"name" : "create_dtm_dl",
"type" : "string"}
]},
"default" : {}
}
]
}
But it does not work. Is it possible to define a new record within a record? Or
should it be done in another way?
My hive tables are in CSV and I have to convert them to JSON so I can post them.
To create this JSON I have to use an AVRO schema. It works fine until the field
"additionalInformation".
I'm not able to generate the fields inside additionalInformation, the only
thing I can do is to say that additionalInformation is a string. But then it
doesn't create the fields that I want and it doesn't post it.
ABove is my AVRO schema trying to create the JSON. The BOLD part is the one
trying to create the additionalInformation field as a record, but it doesn't
work and I have to change the type to string so that it works, but then the
POST body is not json.
The csv file looks like this - maybe I need to change this input file in some
way?
alert_name;animal_number;country;location;alert_id;type_of_alert;alert_date;calving_date;parity;create_dtm_dl
"ketosis_prediction";"NL
743169121";"NL";83618;"KTSPRED_01_817997482";"HOOG_RISICO";"2019-11-08
04:33:38.0";2019-11-07 00:00:00.0;4;2019-11-09 19:13:29.484
"ketosis_prediction";"NL
672760327";"NL";355669;"KTSPRED_01_817997491";"GEMIDDELD_RISICO";"2019-11-08
04:33:41.0";2019-11-07 00:00:00.0;3;2019-11-09 19:13:29.484
Met vriendelijke groet, Kind regards, S pozdravem, Freundlichen Grüßen,
Atenciosamente,
Erwin Speybroeck
Lead Business Consultant | BU Data
[cid:[email protected]]
[cid:[email protected]] (0)26-3898621
[cid:[email protected]] 0032475-252401
[cid:[email protected]]
[email protected]<mailto:[email protected]>
This message is subject to the following E-mail Disclaimer.
(http://www.crv4all.com/disclaimer-email/) CRV Holding B.V. seats according to
the articles of association in Arnhem, Dutch trade number 09125050.
