Support Questions
Find answers, ask questions, and share your expertise
Announcements
Alert: Welcome to the Unified Cloudera Community. Former HCC members be sure to read and learn how to activate your account here.

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

Highlighted

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!!!