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.

Use NIFI REST API's using Python

Use NIFI REST API's using Python

I am seeing lot of curl commands to trigger the NIFI dataflow through REST API's. I would like to know if I can use Python to do similar triggers or curl is the only one recommended? If I can use python as well, can someone explain me how should I construct the headers and binary data and pass the object using Requests module. Thanks for the help.

2 REPLIES 2
Highlighted

Re: Use NIFI REST API's using Python

@Bharath Sudharsanam

Python Curl: https://stackoverflow.com/questions/25491090/how-to-use-python-to-execute-a-curl-command

 


 


If this answer resolves your issue or allows you to move forward, please choose to ACCEPT this solution and close this topic. If you have further dialogue on this topic please comment here or feel free to private message me. If you have new questions related to your Use Case please create separate topic and feel free to tag me in your post.  


 


Thanks,



Steven

Highlighted

Re: Use NIFI REST API's using Python

There is a full Python client for NiFi, NiFi-Registry, and I'm just about to add the Schema-Registry as well.
https://github.com/Chaffelson/nipyapi

It is community supported and comes with all the basic calls you would need to automate your NiFi flows, higher level functions for complex tasks like 'stop all processors in this process group and purge all the queues', and demos of various usage methods like tokenAuth security, promoting flow versions between environments, and deploying NiFi in Docker containers for testing.

Don't have an account?
Coming from Hortonworks? Activate your account here