1、获取Workflow信息
1.1 workflow id
![](https://img2020.cnblogs.com/i-beta/1048291/202003/1048291-20200321100222125-1353386269.png)
1.2 workflow input
![](https://img2020.cnblogs.com/i-beta/1048291/202003/1048291-20200321100307384-955274563.png)
1.3 workflow output
![](https://img2020.cnblogs.com/i-beta/1048291/202003/1048291-20200321100339039-1243457877.png)
2、Python示例代码
import requests
import time
from django.conf import settings
def get_result(result_url, headers, user, password):
"""
执行Workflow执行结果查询
"""
result_response = requests.get(url=result_url, headers=headers, auth=(user, password))
return result_response.json()
def get_vm_owner(user, password, workflow_id, vm_name):
"""
通过VM名称获取VM Owner
"""
submit_url = "https://vro-server-ip/vco/api/workflows/{}/executions".format(workflow_id)
headers = {
"Content-Type": "Application/Json"
}
request_body = {
"parameters": [
{
"type": "string", # input参数类型
"name": "vm_name", # input参数名称
"value": {
"string": {
"value": vm_name # input参数值
}
}
}
]
}
response = requests.post(url=submit_url, headers=headers, json=request_body, auth=(user, password)) # 执行Workflow API异步调用
if response.status_code == 202:
result_url = response.headers.get("Location") # 获取Workflow执行结果的URL
time.sleep(10) # 等待Workflow查询执行完成
try_number = 3 # 尝试3次
while try_number:
result_json = get_result(result_url, headers, user, password) # 查询Workflow执行结果
if result_json.get("state") == "running": # 如果Workflow还在执行中,继续循环
try_number = try_number - 1
time.sleep(3)
continue
if result_json.get("state") == "completed": # 如果Workflow执行完成,获取output值
return result_json.get("output-parameters")[0]["value"]["string"]["value"]
if result_json.get("state") in ["failed", "canceled"]:
return None
if __name__ == '__main__':
owner = get_vm_owner("vro_user", "vro_password", "workflow_id", "vm_name")
print(owner)