Member since
05-06-2021
20
Posts
1
Kudos Received
1
Solution
My Accepted Solutions
Title | Views | Posted |
---|---|---|
981 | 05-17-2021 12:22 PM |
06-01-2022
10:59 AM
1 Kudo
@steven-matison thank you so much.
... View more
06-01-2022
10:10 AM
@steven-matison This is exactly what I needed... before Nifi version 1.16 this was not possible with Failure Relationships?
... View more
05-31-2022
08:21 AM
Good morning everyone,
I have a question regarding the Failure of the ExecuteSQL processor.
I would like to know if when accusing a failure in this processor I can give a Retry in the Processor with its own Failure.
Thanks
... View more
Labels:
- Labels:
-
Apache NiFi
08-17-2021
06:58 AM
Good morning everybody, How do I replace an apostrophe with an empty space in apache Nifi? This apostrophe is coming from an attribute. Thank you very much.
... View more
Labels:
- Labels:
-
Apache NiFi
06-16-2021
10:46 AM
@MattWho @pvillard @Shu_ashu @Dubeyji @VidyaSargur @TimothySpann can You help me?
... View more
06-14-2021
04:43 AM
Good morning everybody, I have a stream where I execute a POST method and I have multiple returns from an API. This flow is executed by an "ExecuteSQL" line by line. I would like to know how to send these returns to Oracle. In some moments the API will return errors in my submission and I need to save them in Oracle too, to later handle these errors. I also need to save the JSON sent to the API and this happens via another stream of the Original from "invokeHTTP". I'm already handling these flows through "EvaluateJSONPath", "ExtractText" and "SplitJSON", but I don't know how to send them to Oracle. Note that I need to group all these streams into just one stream and only one stream at a time to send to Oracle, because I need to pass parameters in the routine that will be sending to Oracle. If anyone knows how to help me I appreciate it. Thank you so much.
... View more
Labels:
- Labels:
-
Apache NiFi
05-21-2021
10:21 AM
@MattWho, Good afternoon. I changed my flow to make a counter by the processor "RouteOnAttribute 1.12.1" so every time I have a record to be sent to the API and have a return to store in Oracle, I do the LOOP through RouteOnAttribut. Thus sending one FlowFile at a time to the PROCEDURE call in Oracle by "ExecuteSQL 1.12.1" But what is happening at the moment is that from the second time it goes through the LOOP, it seems to me that the Flow to get the attributes "CODIGO" and "JSON_ORIGINAL" is not passing the values that I requested in the processor "EvaluateJsonPath 1.12.1" passing the parameters as null. Do you have any idea what may be happening in this second flow passage within the LOOP? This is the JSON ORIGINAL of the second stream that I must send to Oracle = This is OK with the CODE attribute as you can check. This is Split Configure Processor = This is EvaluateJsonPath 1.12.1 Configure Processor = This is MergeContent 1.12.1 Configure Processor = This is ExecuteSQL 1.12.1 Configure Processor =
... View more
05-18-2021
12:04 PM
Good afternoon, I am using the "RouteOnAttribute" processor to do a loop validating a condition that is as follows = ${cont:lt(${CONTADOR})} But I am not able to make the processor understand the property "CONTADOR" Could you help me please?
... View more
Labels:
- Labels:
-
Apache NiFi
-
NiFi Registry
05-17-2021
12:22 PM
@MattWho I was able to use the following structure in the flow = Thanks a lot for the help. 😃
... View more
05-17-2021
11:51 AM
Sorry the correct property for this case is $ {CONTADOR: equals ('N')}
... View more
05-17-2021
11:36 AM
@MattWho I'm trying a different approach using "RouteOnAttribute" with the condition $ {CODE: contains ("N")} after "ConvertAvroToJSON" I thought about putting this condition before all my flow. So already valid if there is a record to be sent by Oracle. But it is not working, a result of the always "unmatched" Even Oracle sending me "N". Could you tell me if this condition I put in is correct?
... View more
05-17-2021
04:00 AM
@mburgess can You help me?
... View more
05-14-2021
01:03 PM
Good afternoon everyone, I have a problem with my flow in the processor "JoltTransformJSON" when I run the processor "ExecuteSQL" and no Oracle record returns to me. I would like your help to know what to do in this case. Thank you so much.
... View more
Labels:
- Labels:
-
Apache NiFi
-
NiFi Registry
05-12-2021
03:25 AM
@MattWho @pvillard @mattw Please can you help me?
... View more
05-10-2021
03:43 AM
Good morning all, Can someone help me?
... View more
05-07-2021
11:58 AM
Good morning everybody, I have the following scenario of returning an API through two streams = Flow 1 ( {"cod": 1} {"cod": 2} {"cod": 3}) Flow 2 ( {"error": "error 1"} {"error": "error 2"} {"error": "error 3"}) Each error has its cod and I need to send it to my database in this way through a procedure through "ExecuteSQL" = procedure (cod => '$ {cod}', error => '$ {error}'); I am trying to do this through "MergeContent" but it is not working. What Nifi is doing is as follows = {"cod": 1} {"cod": 2} {"cod": 3} {"error": "error 1"} {"error": "error 2"} {"error": "error 3" } Not dividing the shipments by code, let's say and passing to "ExecuteSQL" all at once, when Cod + Error would have to be sent one at a time. Follow all my flow = This is my "MergeContent" = This is my "ExecuteSQL" = Can someone help me?
... View more
Labels:
- Labels:
-
Apache NiFi
-
NiFi Registry
05-07-2021
11:02 AM
@MattWho Thanks for the time available for my problem, the "ExtractText" worked perfectly for my case and the data was saved in my database. Grateful.
... View more
05-07-2021
04:10 AM
@MattWho Thank you for your help, This is all my flow: I send a JSON like this : { "User": "user", "Key": "ABC", "Table": "Table", "Rows": [ { "CODIGO": 1, "NOME": "ABC REPRESENTACOES LTDA", "NOME_FANTASIA": "PEDRO LIMA", "ENDERECO": "RUA SANTOS, 178", "BAIRRO": "", "CIDADE": "SAO PAULO", "UF": "SP", "CEP": "11008999", "TELEFONE": "(11) 99887 1234", "EMAIL": "pedro.lima@email.com", "FUNCAO": "REPRESENTANTE", "CODIGO_SUPERIOR": "", "CNPJ": "", "INSCRICAO_ESTADUAL": "", "NRO_CONTRATO": "8918-A", "NRO_REG_EMPREGADO": "", "DATA_CONTRATACAO": "2018/06/28", "DATA_DESLIGAMENTO": "", "SITUACAO": "ATIVO", "REGIAO": "SP" } ] } And at some point the API called returns an error, that at some point I need to deal with in order to insert the error in our database. This error is expected in the HTTP response. Follows the configuration of the processors: ReplaceText = EvaluateJsonPath = This is Response Before Replace Text = {"RegistrosRecebidos":1,"RegistrosImportados":0,"Erros":["Erro registro 0: The statement has been terminated.\r\nString or binary data would be truncated in table \u0027Ober_HML.dbo.DB_WS_IMP_CLIENTE\u0027, column \u0027NOME_FANTASIA\u0027. Truncated value: \u0027ADLER PELZER PERNAMBUCO IND. E COMERCIO \u0027."]} What I need is to take the value of the "Errors" property and save it in my database, only when trying to do this with EvaluateJsonPath it returns the following error: For this reason I am trying to use ReplaceText but also without success. I don't know if I managed to be clear enough in my doubt.
... View more
05-06-2021
04:40 AM
Good morning everybody, I have the following JSON return: { "RegistrosRecebidos" : 1, "RegistrosImportados" : 0, "Erros" : [ "Erro registro 0: The statement has been terminated.\r\nString or binary data would be truncated in table 'Ober_HML.dbo.DB_WS_IMP_CLIENTE', column 'NOME_FANTASIA'. Truncated value: 'ADLER PELZER PERNAMBUCO IND. E COMERCIO '." ] } By default from our supplier, it comes with some formatting. That in Nifi gives the following error: Follow my flow: How can I do to solve this problem in Nifi? I am trying to use ReplaceText for this but I have not been successful. Thanks.
... View more
- Tags:
- NiFi
- NiFi Registry
Labels:
- Labels:
-
Apache NiFi
-
NiFi Registry