Hello everyone! I'm new to Apache Nifi and I'm trying to get some data from a database (db1), perform a lookup using another another database (db2) and then loading this new data into a redshift. The problem is that my LookUp Process fails.
The incoming data from the db1 looks like the following:
{
transacition_id: 123
customer_id: 321
amount: U$10.0
}
On the db2 I have this:
{
pk_customer: 001
src_sys_key: 321
customer_name: "example"
}
What I would like to do is get the pk_customer from the db2 by matching customer_id with src_sys_key.
The current Nifi flow:
![1Dhpf.png 1Dhpf.png](https://community.cloudera.com/t5/image/serverpage/image-id/35897i9D93C353D5ACBCC1/image-size/medium?v=v2&px=400)
LookupRecord settings:
![L6YBh.png L6YBh.png](https://community.cloudera.com/t5/image/serverpage/image-id/35898i4BA0586A53AD9286/image-size/medium?v=v2&px=400)
And finally the LookupService (Database Record Lookup):
![spGLM.png spGLM.png](https://community.cloudera.com/t5/image/serverpage/image-id/35899iD29BCCAF258286FD/image-size/medium?v=v2&px=400)
Getting the following error:
![gJkTW.png gJkTW.png](https://community.cloudera.com/t5/image/serverpage/image-id/35900i425626212D1BA64F/image-size/medium?v=v2&px=400)
Can anyone help me, please?
Thank you in advance!