Our Community is getting an upgrade! To get everything ready for the relaunch, we’ll be placing the site in read-only mode starting September 21st.
We really appreciate your understanding while we get things set up behind the scenes. Catch up on all the exciting details about the move here.
Need help or have questions? Drop us a line at [email protected]
Created 10-05-2017 02:09 PM
Can Oozie invoke and RestFul service for notification ? Is there an example which can be used ...
Created 10-05-2017 02:34 PM
you can make use of oozie java action or oozie shell action to make the REST API calls.
https://oozie.apache.org/docs/3.2.0-incubating/WorkflowFunctionalSpec.html#a3.2.7_Java_Action
https://oozie.apache.org/docs/3.3.0/DG_ShellActionExtension.html
below is a sample shell action calling python code
<action name="metrics"> <shell xmlns="uri:oozie:shell-action:0.2"> <job-tracker>${RESOURCE_MANAGER}</job-tracker> <name-node>${NAME_NODE}</name-node> <exec>oozie_hook.py</exec> <argument>host</argument> <argument>port</argument> <file>${APP_PATH}/shell/oozie_hook.py#oozie_hook.py</file> </shell> <ok to="end"/> <error to="kill"/> </action>
below is a sample python code ( not working for reference )
url = "http://" + sys.argv[1] + ": " + sys.argv[2] + "/workflow/" r = requests.get(url,timeout=60)
Created 10-05-2017 02:34 PM
you can make use of oozie java action or oozie shell action to make the REST API calls.
https://oozie.apache.org/docs/3.2.0-incubating/WorkflowFunctionalSpec.html#a3.2.7_Java_Action
https://oozie.apache.org/docs/3.3.0/DG_ShellActionExtension.html
below is a sample shell action calling python code
<action name="metrics"> <shell xmlns="uri:oozie:shell-action:0.2"> <job-tracker>${RESOURCE_MANAGER}</job-tracker> <name-node>${NAME_NODE}</name-node> <exec>oozie_hook.py</exec> <argument>host</argument> <argument>port</argument> <file>${APP_PATH}/shell/oozie_hook.py#oozie_hook.py</file> </shell> <ok to="end"/> <error to="kill"/> </action>
below is a sample python code ( not working for reference )
url = "http://" + sys.argv[1] + ": " + sys.argv[2] + "/workflow/" r = requests.get(url,timeout=60)
Created 10-25-2018 10:29 AM
Why would you do that??? Why won't you just curl from the shell action? A part of me would die if I do this in my workflow!