About Kiranq

Kiranq · ‎10-02-2023

@araujo I am trying to implement your suggested way. My json is : { "Id" : "some int", "TenantId" : "some double value" } and I am using chain jolt transform method as: [ { "operation": "shift", "spec": { "*": { "@(1,Id)": "[&1].Id", "@(1,TenantId)": "[&1].TenantId" } } }] However, I am getting a error as: Can you tell where I am going wrong? Thanks.

Kiranq · ‎08-31-2023

@SAMSAL, hey I know I accepted the solution and it did work for when I had 1 user details to fetch and store it's values to the processor's attributes. I wanted to ask if it is possible to store multiple values to a single attribute of a processor since I now have many users' details to store. Is this possible otherwise I would have to change the logic? Thanks.

Kiranq · ‎08-30-2023

Yes, I ended up changing my ExecuteScript in a way that all column's values are now attributes of my flowFile. Next, I have added PutSql processor and inserting data using ${attributename}. Thanks @SAMSAL for responding.

Kiranq · ‎08-29-2023

Thanks @SAMSAL for responding. I will explain what I am trying to accomplish. The ExecuteStreamCommand gives me below results: and I want to use displayName and mail key's values from this result and store it into the database. My current workflow is based on the flow that I will store these two key's value as a attribute and use it in the subsequent processors. However, using AttributestoJson aint also working for me. Can you suggest any other better appraoach to ingest these two values in my database? I have other columns' value to ingest that as well so may be ExecuteSQLCommand processor would be a better choice to use.

Kiranq · ‎08-29-2023

I am executing python script in ExecuteStreamCommand and my code last line dumps the json key values. My goal is to read those key values into PutDatabaseRecord processor and insert the values in my database. However, I am unable to read content of the flow file of ExecuteStream. I have used ConvertAvrotoJson but it is showing output as "not a avro data file". Is there any workarounf of it? Thanks.

Kiranq · ‎08-28-2023

Thanks for the reply. I did it in the same way you have mentioned (I am importing Selenium module and from this module, Service, WebDriverWait and EC components are imported) but late in the code execution, my scripts gives an error "global name Service is not defined". Any idea whats causing the issue?

Kiranq · ‎08-28-2023

@joseomjr I am trying to replicate your suggested method, please answer did you include the import command after sys.path.append command?

Kiranq · ‎08-17-2023

Thanks. It was an issue with the connection string. It was pointing to another database while my processor was inserting into another database.

Kiranq · ‎08-13-2023

Should I be using "use statement" in my sql select query?

Kiranq · ‎08-13-2023

Hi, My task is to move data from my locally installed SQL server (16.0) to Azure SQL (12.0) hosted on my Azure subscription. So far, I have used ExecuteSQL processor to run my select query from SQL Server and it returns me the rows successfully. I have created a Database Polling Connection Service which connect to my SQL Server. After fetching the rows, I am using PutDatabaseRecord processor to insert the fetched rows into Azure SQL but its showing me error that "use statement is not supported to switch between databases". Note that the Database Polling Connection Service is different for PutDatabaseRecord where I have mentioned connection string of my Azure SQL. Please if anyone can give feedback on this issue and suggest any workaround.

Online	Offline
Last Visited	‎11-17-2025 09:45 PM

Member Since	‎05-30-2023 04:10 AM
Last Visited	‎11-17-2025 09:45 PM
Posts	45
Kudos received	4

Cloudera Community

Re: convert json to csv in nifi

Re: Read the flow file of ExecuteStreamCommand

Re: Read the flow file of ExecuteStreamCommand

Re: Read the flow file of ExecuteStreamCommand

Read the flow file of ExecuteStreamCommand

Re: Unable to import python external modules in ni...

Re: Unable to import python external modules in ni...

Re: Move data from locally installed SQL Server to...

Re: Move data from locally installed SQL Server to...

Move data from locally installed SQL Server to Azu...