Zack Meier
119 lines
3.7 KiB
Python
119 lines
3.7 KiB
Python
#!/usr/bin/python
|
|
import sys,argparse,json,time
|
|
sys.path.insert(0, './classes/')
|
|
|
|
import cohesityAPI as cohesity
|
|
|
|
def GetArgs():
|
|
parser = argparse.ArgumentParser(add_help=False)
|
|
parser.add_argument('--cluster', '-c', type=str, action='store')
|
|
parser.add_argument('--vcenter', '-v', type=str, action='store')
|
|
parser.add_argument('--job', '-j', type=str, action='store')
|
|
parser.add_argument('--help', '-h', action='store_true')
|
|
return (parser.parse_args())
|
|
|
|
def PrintHelp():
|
|
print("\nBasic Usage:")
|
|
print("Set OS environment variables ITD_SHAREPOINT_PASS and ITD_SHAREPOINT_USER")
|
|
print("\nExample:")
|
|
print(r"$ export COHESITY_USER=\"NDGOV\jDoe\"")
|
|
print("$ export COHESITY_PASS=\"1Lik3Jane\"")
|
|
print("\n python3 <SCRIPT_NAME> -c cluster1.domain.tld [ -v vCenter.domain.tld ] [ -j protectionJobName ]")
|
|
print("\t -c FQDN of Cohesity cluster address")
|
|
print("\t -v FQDN of vCenter Server, used in conjuntion with -t kVMware ")
|
|
print("\t -j Cohesity job name")
|
|
print("\t -h Prints this help message")
|
|
|
|
args = GetArgs()
|
|
|
|
if args.help:
|
|
PrintHelp()
|
|
|
|
if not args.cluster:
|
|
sys.exit("Error: Specify Cohesity cluster fqdn with -c parameter.")
|
|
else:
|
|
cluster = cohesity.API(args.cluster)
|
|
authToken = cluster.GetAuthToken()
|
|
cluster.UpdateHeaders(authToken['accessToken'])
|
|
|
|
if args.vcenter:
|
|
vmSources = cluster.GetFilteredRequest("/public/protectionSources", "?environments=kVMware")
|
|
|
|
for source in vmSources:
|
|
if source['protectionSource']['name'] == args.vcenter:
|
|
vCenter = source
|
|
vCenterID = source['protectionSource']['id']
|
|
break
|
|
|
|
if args.job:
|
|
# Get the details of a single job
|
|
vmJobs = cluster.GetFilteredRequest("/public/protectionJobs", "?names=" + args.job)
|
|
else:
|
|
# Get the details of all jobs under a vCenter
|
|
vmJobs = cluster.GetFilteredRequest("/public/protectionJobs", "?environments=kVMware")
|
|
|
|
uniqueJobs = {job['id'] : job for job in vmJobs}.values()
|
|
|
|
# Do stuff with the JSON data
|
|
# Example:
|
|
if args.pause:
|
|
pausedJobs = []
|
|
for job in uniqueJobs:
|
|
if job['parentSourceId'] != vCenterID:
|
|
print("not vcenter")
|
|
continue
|
|
|
|
elif "isDeleted" in job:
|
|
continue
|
|
|
|
elif "isPaused" in job:
|
|
if job['isPaused']:
|
|
pausedJobs.append(job)
|
|
continue
|
|
|
|
print("Pausing: " + job['name'])
|
|
resp = cluster.PauseJob(job['id'])
|
|
|
|
print("The following jobs were previously paused before this operation.")
|
|
for pJob in pausedJobs:
|
|
print(pJob['name'])
|
|
|
|
if args.resume:
|
|
for job in uniqueJobs:
|
|
if job['parentSourceId'] != vCenterID:
|
|
continue
|
|
|
|
elif "isDeleted" in job:
|
|
continue
|
|
|
|
print("Resuming: " + job['name'])
|
|
resp = cluster.ResumeJob(job['id'])
|
|
|
|
elif args.job:
|
|
job = cluster.GetFilteredRequest("/public/protectionJobs", "?names=" + args.job)
|
|
|
|
job[0].update({"indexingPolicy":{
|
|
"disableIndexing": False,
|
|
"allowPrefixes": [
|
|
"/"
|
|
],
|
|
"denyPrefixes": [
|
|
"/$Recycle.Bin",
|
|
"/Windows",
|
|
"/ProgramData",
|
|
"/System Volume Information",
|
|
"/Users/*/AppData",
|
|
"/Recovery",
|
|
"/usr",
|
|
"/sys",
|
|
"/proc",
|
|
"/lib",
|
|
"/grub",
|
|
"/grub2",
|
|
"/opt/splunk",
|
|
"/splunk",
|
|
]
|
|
}})
|
|
|
|
resp = cluster.UpdateVMProtectionJob(job[0])
|