Member since
07-29-2020
526
Posts
266
Kudos Received
158
Solutions
My Accepted Solutions
Title | Views | Posted |
---|---|---|
84 | 09-07-2024 12:59 AM | |
161 | 09-03-2024 12:36 AM | |
153 | 08-30-2024 06:23 AM | |
435 | 08-26-2024 04:39 PM | |
217 | 08-21-2024 12:01 PM |
05-11-2023
11:43 AM
Hi, Please see the modified spec below. The comments indicate what I had to do to make your modify-overwrite-beta spec works based on the input json. I hope it works. [{
"operation": "modify-overwrite-beta",
"spec": {
"FatturaElettronicaBody": {
// The DatiGenerali level is not found in the input JSON
// "DatiGenerali": {
"DatiBeniServizi": {
"DettaglioLinee": {
"*": {
//level3
"ScontoMaggiorazione": {
// level2
"*": {
// Quantita is located level 3 and not level 1
"Importo": "=divide(@(1,Importo),@(3,Quantita))"
}
}
}
}
}
//}
}
}
}]
... View more
05-11-2023
09:28 AM
Hi, Will that helps: https://stackoverflow.com/questions/45052625/how-can-i-change-the-timezone-of-a-column-in-apache-nifi
... View more
05-08-2023
12:48 PM
Hi, I believe this spec would help with setting the date as default date in each array element: [
{
"operation": "modify-overwrite-beta",
"spec": {
"FatturaElettronicaBody": {
"DatiGenerali": {
"DatiDDT": {
"NumeroDDT": "=split('[,]',@(1,NumeroDDT))"
}
}
}
}
},
{
"operation": "shift",
"spec": {
"FatturaElettronicaBody": {
"DatiGenerali": {
"DatiGeneraliDocumento": "FatturaElettronicaBody.DatiGenerali.&",
"DatiDDT": {
"NumeroDDT": {
"*": {
"@": "FatturaElettronicaBody.DatiGenerali.DatiDDT[&1].NumeroDDT",
"@(3,DatiGeneraliDocumento.Data)": "FatturaElettronicaBody.DatiGenerali.DatiDDT[&1].Date"
}
}
}
}
}
}
}
] If that helps please accept solution.
... View more
05-08-2023
10:27 AM
1 Kudo
What is the "Completion Strategy" property under FetchSFTP is set to? If its set to the default "None" then the file should not be deleted or moved. See the Completion Strategy options under: https://nifi.apache.org/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.20.0/org.apache.nifi.processors.standard.FetchSFTP/index.html If that helps please accept solution.
... View more
05-08-2023
09:47 AM
if what you provided seems to be giving you the expected output then you are good to go :).
... View more
05-08-2023
07:58 AM
Hi, See if this helps: [
{
"operation": "shift",
"spec": {
"header": {
"timeStamp": "records.inv_activity_ts",
"activityId": "records.inv_activity_id",
"action": "records.action"
},
"resource": {
"drniId": "records.inv_id",
"subtype": "records.inv_subtype",
"name": "records.inv_name",
"resourceCharacteristic": {
"*": {
"name": {
"status": {
"$": "records.status",
"@(2,value)": "records.matchingStatus_value"
},
"installDate": {
"@(2,value)": "records.installDate"
}
}
}
}
}
}
}
] If that helps please accept solution. Thanks
... View more
05-07-2023
05:05 PM
1 Kudo
@ThienTrinh, As workaround you can follow this scenario: https://stackoverflow.com/questions/55118389/i-have-two-json-payload-i-want-to-merge-them-in-a-single-json-object/55124212#55124212
... View more
05-06-2023
09:06 AM
1 Kudo
I can confirm that there is behavior change in Fork\Join Enrichment processors between 1.16 and 1.20. I have uploaded the same template you sent using 1.16 and it worked using 1.16 JsonTreeReader\Writer , however the same template did not work on 1.20 using 1.20 processors and services. @MattWho, @steven-matison Is this a bug or misunderstanding if how such processors and services should work in the later versions? Please advise. Thanks
... View more
05-05-2023
01:39 PM
2 Kudos
Hi, One of the main differences that I can see is that the QueryDatabaseTableRecord has a RecordWriter which allows you to to decide the format of the output (Json, xml, csv , parquet ...etc.) where a service need to be setup for the record writer depending on the format, while the QueryDatabaseTable will only provide an Avro format output without the need to setup any record writer service. This is similar to the case of processors ExecuteSQL vs ExecuteSQLRecord. Another important difference I see is the QueryDatabaseTable has property setting for "Transaction Isolation Level" while the other doesn't If that helps please accept solution. Thanks
... View more
05-05-2023
06:37 AM
Hi, I'm not seeing any difference in the JsonTreeReader\Writer . I'm not sure why you are not getting the expected output. The only difference I see is that I'm using 1.16 version and you are on 1.20 so I'm not sure if the behavior is different between the two versions even though I suspect its the case. To troubleshoot and find out , try to create the same flow I created and use the GeneratedFlowFile and ReplaceText to generate the output A & B from your post above. If that works then I would double check your original flow and make sure that InvokeHttp is generating the desired output and the same response output is making it to the ForkEnrichment\JoinEnrichment as designed. Let me know how that goes.
... View more