oozie-webservice-api 0.2

Python wrapper for Oozie Webservice REST API

# python-oozie-webservice-api

## About

This is Python Library for Oozie Web service api.

This project follows the [Oozie 4.2.0 WebServicesAPI](https://oozie.apache.org/docs/4.2.0/WebServicesAPI.html) document.

## How to install and run

## Examples

```python
#!/usr/bin/env python
# -*- coding: utf-8 -*-
from sdk.oozie.ws.OozieWebservice import OozieWebservice

def main():

oozie = OozieWebservice("localhost", 11000)

## version
oozie.versions()

## admin
oozie.status()

oozie.change_system_mode("NOWEBSERVICE")
oozie.change_system_mode("SAFEMODE")
oozie.change_system_mode("NORMAL")

oozie.os_env()
oozie.java_sys_properties()
oozie.configuration()
oozie.metrics()
oozie.build_version()
oozie.available_timezones()
oozie.queue_dump()
oozie.available_oozie_servers()
oozie.list_sharelib()
oozie.list_sharelib("hive*")
oozie.update_sharelib()

oozie.submit_job(jobxml)
oozie.submit_job(jobxml, True)
oozie.submit_proxy_job('hive', proxyxml)

oozie.managing_job("0006357-ID-OOZIE", "kill")
oozie.managing_job("0006351-ID-OOZIE", "rerun", rerun_xml)
oozie.rerunnig_coord_by_action_id("0005928-ID-oozie-bpse-C", "23-24")
oozie.rerunnig_coord_by_date("0005928-ID-oozie-bpse-C", "2018-08-19T21:00Z", "2018-08-19T23:00Z")

oozie.rerunnig_bundle_by_action_name("0006373-ID-oozie-bpse-B", ["CL_1"])
oozie.rerunnig_bundle_by_date("0006373-ID-oozie-bpse-B", "2018-09-12T01:00Z", "2018-09-12T02:00Z")

oozie.change_coord_info("0005931-ID-oozie-bpse-C", pausetime="2030-09-12T02:00Z")
oozie.update_coordinator("0006384-ID-oozie-bpse-C", update_coord_xml)

oozie.job_info("0006300-ID-OOZIE")
oozie.job_info("0006420-ID-oozie-bpse-C", show="definition")
oozie.job_info("0000344-ID-oozie-bpse-C@1")
oozie.job_info("0000344-ID-oozie-bpse-C@1", show="allruns", type="action")
oozie.job_info("0005928-ID-oozie-bpse-C", filters='status=SKIPPED', offset=1, len=1, order='desc')
oozie.job_info("0006300-ID-OOZIE", show="definition")
oozie.job_info("0006300-ID-OOZIE", "log")
#oozie.job_info("0006300-ID-OOZIE", "errorlog")
#oozie.job_info("0005931-ID-oozie-bpse-C", "auditlog")
oozie.job_log("0006300-ID-OOZIE")
oozie.job_log("0006300-ID-OOZIE", show="errorlog")
oozie.job_log("0005928-ID-oozie-bpse-C", show="auditlog")
oozie.job_log("0006300-ID-OOZIE", logfilter="limit=3;loglevel=WARN")
oozie.job_graph("0006300-ID-OOZIE", file_location="C:/Users/User/Desktop/", showkill="false")
oozie.job_status("0006394-ID-oozie-bpse-C")


oozie.jobs_information()
oozie.jobs_information(1, 1)
oozie.jobs_information(10, 1, status="RUNNING")
oozie.jobs_information("coordinator", 10, 1)
oozie.jobs_information("wf", 10, 1)
oozie.jobs_bulk_modify("kill", "wf", 1, 1, status="RUNNING")
oozie.jobs_bulk_bundle_information("BUNDLE_TEST")
oozie.jobs_bulk_bundle_information("BUNDLE_TEST", coordi_names=["CL_1", "CL_2"], action_status="RUNNING")
oozie.jobs_bulk_bundle_information("BUNDLE_TEST", coordi_names=["CL_1", "CL_2"], endScheduledTime="2018-09-13T07:00Z")

oozie.managing_job_coordinator("0005931-ID-oozie-bpse-C")
oozie.managing_job_coordinator("0005931-ID-oozie-bpse-C", managing_type="action", scope="4")
```