Support Questions
Find answers, ask questions, and share your expertise

NiFi flow/pattern for deleting a MySQL record if not found in source DataFlow?

New Contributor

Hi! First question here!

I'm doing an InvokeHTTP >>> PutSQL with whatever comes from an external API. In the database, I'm doing a REPLACE INTO using that external API's primary key.

The problem is that I'd like to delete the rows in my DB that are not found anymore in the first InvokeHTTP, so I have my DB synched with the source API. Sounds like a pattern might fit but I still cannot find it, or maybe I'm asking the wrong questions!

Any ideas?

Tanks in advance!!!