I use NiFi PutS3Object to load a file into an S3 bucket and use an Airflow S3Sensor to monitor that location and kick off an Airflow DAG. I'm trying to change my process to do that via the NiFi InvokeHTTP processor calling the Airflow experimental API ( https://airflow.apache.org/api.html ), because I want the process more tightly coupled. Does anyone know of a better way? ... View more