Member since
05-30-2023
38
Posts
3
Kudos Received
0
Solutions
03-26-2024
10:25 AM
Any feedback would be appreciated.
... View more
03-26-2024
05:30 AM
I have extracted below json from my executesql processor: { "Id" : "B2606868-F4BC-4230-9749-A083F6D222B2", "ReminderPlan" : "-5d, -1d'", "ModifiedOn" : "2024-01-03 19:56:59.0000000" } and I have several of these. The task at my hand is to extract the reminderplan value and pass it as an attribute to some sql processor and run a sql function on that reminderplan column value; for example: DECLARE @output varchar(255); SET @output = NewDemo.dbo.StandardizeReminderPlan('-5d, -1d') SELECT @output AS Result; After storing output value in Result, I want to insert the function value back in the same json. Could anyone suggest which processors I should use to accomplish this?
... View more
Labels:
- Labels:
-
Apache NiFi
02-02-2024
12:00 AM
1 Kudo
Any feedback would be appreciated.
... View more
02-01-2024
05:00 PM
I am trying to access a .py file present in one of the docker container and I am using execute stream command processor for it. However, I am receiving "Permission Denied" error on the .py file. Even though, the file has all the rights given but still facing this issue. Any feedback will be appreciate. Thanks.
... View more
Labels:
- Labels:
-
Apache NiFi
10-19-2023
04:50 AM
I resolved the issue. I had DepartmentId in my avro schema however, I was getting DepartmentID in the input. Schemas are case sensitive. Now, that the string values are appended in the DepartmentID column, I am using RouteOnContent processors and using ${DepartmentID:equals('Undefined')} to match if the DepartmentID' values are of undefined or null type. It is not identifying the "Undefined" values. is the regex statement correct? Content of flow file is: [ { "TenantId" : "FF369226-0EDA-4D0D-B48C-6B27F404ECCB", "DepartmentID" : "Undefined", "Name": "xyz" } ]
... View more
10-19-2023
03:55 AM
I am reading avro flow flow (using embedded schema) and for writing it, I am providing schema.text. My schema text is this: { "name": "nifi", "type": "record", "fields": [ { "name": "TenantId", "type": ["null","string"] }, { "name": "DepartmentId", "type": ["null","string"] }, { "name": "Name", "type": ["null","string"] } ] } The issue is its not retaining DepartmentID as strings and converting them to null.
... View more
10-19-2023
01:18 AM
Hi all. I have two avro-binary types of flow files and their content is: Flow file one: [ { "DepartmentID" : "Undefined", "Name" : "Non Billable", } ] Flow file two:[ { "DepartmentID" : "Null", "Name" : "Tax", } ] I am using UpdateRecord processor to add a key:value (tenantId) in the same file for which I am using below avro schema: { "name": "nifi", "type": "record", "fields": [ { "name": "TenantId", "type": ["null","string"] }, { "name": "DepartmentId", "type": ["null","string"] }, { "name": "Name", "type": ["null","string"] } ] } I am using literal value replacement value strategy and getting TenantId from previous processors. So far, this is a success and tenantId is appended. However, as a result, the DepartmentId changes to null for BOTH the files. Where I can ensure that the DepartmentId's values are not changed because based on these values, I have to route the "undefined" file for further processing. Any help would be appreciated. Thanks.
... View more
Labels:
- Labels:
-
Apache NiFi
10-02-2023
10:12 AM
Thats right. I intend to convert the json using JoltTransfomationRecord into csv format and then save the file in my local machine.
... View more
10-02-2023
09:40 AM
@SAMSAL thank you for responding. I am infact using/converting the output from ExecuteSql from Arvo to Json using ConvertAvroToJson processor. Below is the output of the same processor: I am also wondering if I am providing the json format, its throwing error for avro. Can you suggest something?
... View more