I'm not sure when I need to access the configuration from a role (or a group) as opposed to using the service directly, but based on a separate communication I used the role. The snippet of code below is based on a working version (on a quickstart vm), and looks like: # peforms the post install oozie service management for the red orbit module
def main():
cmhost = 'quickstart.cloudera'
theUserName = "admin"
thePassword = "admin"
apiResource = ApiResource(cmhost, username=theUserName, password=thePassword)
# A kludgey way of specifying the cluster, but there is only one here
clusters = apiResource.get_all_clusters()
# TODO: This is a kludge to resolve the cluster
if (len(clusters) != 1):
print "There should one cluster, but there are " + repr(len(clusters)) + " clusters"
sys.exit(1)
cluster = clusters[0]
# TODO: These parameters are appropriate for the quick start vm, are they right for our deployment?
hueServiceName = "hue"
oozieServiceName = "oozie"
oozieServiceRoleName = 'oozie-OOZIE_SERVER'
oozieService = cluster.get_service(oozieServiceName)
hueService = cluster.get_service(hueServiceName)
oozieServiceRole = oozieService.get_role(oozieServiceRoleName)
# TODO: Is this always going tobe the oozie service role's name? We may need to use the Role Type to be safe
originalOozieConfig = oozieServiceRole.get_config(view='full')
oozieConfigUpdates = { "oozie_executor_extension_classes" : "org.apache.oozie.action.hadoop.MyCustomActionExecutor",
"oozie_workflow_extension_schemas" : "my-custom-action-0.1.xsd" }
for configUpdateKey in oozieConfigUpdates:
if (configUpdateKey in originalOozieConfig):
print repr(configUpdateKey) + " before update has oozie configured value = " + str(originalOozieConfig[configUpdateKey])
else:
print repr(configUpdateKey) + " not previously configured in oozie"
# stop the oozie service after stoping any services depending on oozie (i.e. hue)
for service in [hueService, oozieService]:
print "stopping service " + repr(service.name)
service.stop().wait() # synchronous stop
print "service " + repr(service.name) + " stopped"
# update the configuration while the servers are quiescent
updatedOozieConfig = oozieServiceRole.update_config(oozieConfigUpdates)
print "updatedOozieConfig = " + repr(updatedOozieConfig)
for configUpdateKey in oozieConfigUpdates:
print 'Config after update for key = ' + repr(configUpdateKey) + " has value = " + repr(updatedOozieConfig[configUpdateKey])
# restart the oozie service before restarting any services depending on oozie (i.e. hue)
for service in [oozieService, hueService]:
print "retarting service " + repr(service.name)
service.restart().wait() # synchronous restart
print "service " + repr(service.name) + " restarted"
# Done!
return
... View more
