Member since
05-06-2021
37
Posts
1
Kudos Received
1
Solution
My Accepted Solutions
| Title | Views | Posted |
|---|---|---|
| 5112 | 05-17-2021 12:22 PM |
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
- « Previous
- Next »