用python实现,在600s内持续获取taskstatus,如果"无法到达"或"定位丢失"再taskstatus中出现,那任务就判定为失败。相反就等待1s再去获取taskstatus
时间: 2024-06-10 22:07:24 浏览: 52
Hadoop源代码分析(类TaskStatus)
可以使用Python中的requests库发送请求,不断获取taskstatus,当出现"无法到达"或"定位丢失"时,任务判定为失败。以下是一个示例代码:
```python
import requests
import time
def get_task_status():
url = 'http://example.com/get_task_status'
response = requests.get(url)
status = response.json().get('status')
return status
start_time = time.time()
while True:
status = get_task_status()
elapsed_time = time.time() - start_time
if status in ['无法到达', '定位丢失']:
print('任务失败')
break
elif elapsed_time >= 600:
print('超时')
break
else:
time.sleep(1)
```
请注意,这仅仅是一个示例代码,实际代码需要根据您的具体需求进行修改。
阅读全文