Python调用MoiaControl重做接口

本文遵循BY-SA版权协议,转载请附上原文出处链接。


本文作者: 黑伴白

本文链接: http://heibanbai.com.cn/posts/7fcecde8/

Python调用MoiaControl(V5)重做接口示例,具体代码如下:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
# -*- coding: utf-8 -*-
import json
import re
import requests
from requests.auth import HTTPBasicAuth

# web登录用户
userName="admin"
# web登录密码
passWord="admin"
# 此接口用于对节点发起当日重做、依赖链重做和自定义重做命令
interfaceUrl="http://199.188.166.110:8080/MoiaControl/rest/RestService/nodeRedo"
# redoType N String 重做类型:1=当日重做 2=依赖链重做 3=自定义重做
# redoDate N String 重做日期,计划当日重做以及自定义重做时填写
# runType Y String 作业运行方式,作业自定义重做时填写:0=正常执行、1=指定节点、2=随机节点
# pnode Y String 指定执行节点名称,作业自定义重做且运行方式为指定节点时填写
# params Y Map 重做参数列表,自定义重做时填写
# interpose N Object Interpose人工干预参数,参见RMI中断

# Interpose参数说明
# nodeType N Int 节点类型:1=PLAN,2=TASK,3=SEQ,4=JOB,5=CTR
# nodeName N String 节点名称
# taskNode N String 任务节点名称,作业流、作业节点填写
# planDate Y String 计划日期,不定期计划有效
# orgName Y String 机构号,不定期计划有效
# batchNum Y Int 批次号,不定期计划有效

# 用列表存储要删除的任务节点清单
taskNodesList=['a','b','c']

# 定义接口调用函数 通过post调用restful接口
# 采用HTTPBasicAuth一种简单的身份认证,它是通过http的authorization请求头中,携带经过base64加密的用户名和密码而实现的一种认证
def request_post(url, param, user, pwd):
try:
headers = {'charset': 'utf-8'}
result = requests.post(url, data=param, auth=HTTPBasicAuth(user,pwd))
# print("STATUS_CODE:{0}".format(result.status_code))
# print("REASON:{0}".format(result.reason))
# print("CONTENT:{0}".format(result.content.decode()))
text=result.content.decode()
return text
except Exception as e:
print(e)


# 参数
interpose={
"nodeType":1,
"nodeName":"PLAN_003",
"taskNode":"",
"planDate":"",
"orgName":"",
"batchNum":""
}
paramInfo={
"redoType":"1",
"redoDate":"20220528",
"runType":"",
"pnode":"",
"params":(),
"interpose":"%s" % interpose
}

# 开始调度接口
resInfo = request_post(interfaceUrl, paramInfo, userName, passWord)
# print(json.loads(resInfo))

result=json.loads(resInfo)["done"]
describe = json.loads(resInfo)["describe"]

if result:
print("成功: %s" % (describe))
else:
print("失败: %s" % (describe))

蚂蚁🐜再小也是肉🥩!


Python调用MoiaControl重做接口
http://heibanbai.com.cn/posts/7fcecde8/
作者
黑伴白
发布于
2022年3月2日
许可协议

“您的支持,我的动力!觉得不错的话,给点打赏吧 ୧(๑•̀⌄•́๑)૭”

微信二维码

微信支付

支付宝二维码

支付宝支付