建站
咨询
售后
建站咨询
通过flask框架写成http接口调用Ansible-创新互联
#*******一、flask_ansible.py文件
#!/usr/bin/env python
#_*_ coding:utf-8 _*_
import json
from flask import Flask,request
from ansible_api_job import Ansibles
app = Flask(__name__)
@app.route('/ansible/command', methods=['GET','POST'])
def command():
if request.method == 'POST':
jsondata = request.get_data()
dictdata = json.loads(jsondata)
ansible = Ansibles(dictdata['host']) #实例化Ansible对象
res = ansible.shell(dictdata['command'])
return res
else:
return 'Access error
'
@app.route('/ansible/copyfile', methods=['GET','POST'])
def copyfile():
if request.method == 'POST':
jsondata = request.get_data()
dictdata = json.loads(jsondata)
ansible = Ansibles(dictdata['targethost']) #实例化Ansible对象
res = ansible.copyfile(str(dictdata['srcfile']),str(dictdata['dectdir']))
return res
else:
return 'Access error
'
@app.route('/ansible/pullfile',methods=['GET','POST'])
def pullfile():
if request.method == 'POST':
jsondata = request.get_data()
dictdata = json.loads(jsondata)
ansible = Ansibles(dictdata['srchost'])
res = ansible.pull(dictdata['pullsrcfile'], dictdata['savelocaldir'])
return res
else:
return 'Access error
'
if __name__ =='__main__':
app.run(debug=True,host='0.0.0.0')
#************二、ansible_api_job.py文件
#!/user/bin/eng python
# -*- coding=utf-8 -*-
import ansible.runner
class Ansibles(object):
def __init__(self,hostname):
self.hostlist = "host.txt"
self.user = "root"
self.passwd = "1qaz#EDC"
self.pattern = "vmserver"
self.hostname = hostname
hostlist = self.hostname.split(',')
hostfile = open('host.txt', 'w+')
hostfile.writelines('[vmserver]' + '\n')
for line in hostlist:
hostfile.writelines(line + '\n')
hostfile.close()
def shell(self,command):
results = ansible.runner.Runner(
host_list= self.hostlist,
remote_user = self.user,
remote_pass = self.passwd,
module_name = 'shell',
module_args = command,
pattern = self.pattern,
forks = 10
).run()
for (hostname,result) in results['contacted'].items():
if result['stdout'] == "":
return "HOST:%s, ERROR>>(%s)" % (hostname, result['stderr'])
else:
return "HOST:%s, RESULTS>>(%s)" % (hostname, result['stdout'])
def copyfile(self,srcfile,dectdir):
results = ansible.runner.Runner(
host_list=self.hostlist,
remote_user=self.user,
remote_pass=self.passwd,
module_name='copy',
module_args='src=%s dest=%s' % (srcfile,dectdir),
pattern=self.pattern,
forks=10
).run()
for (hostname,result) in results['contacted'].items():
if 'failed' in result:
return "HOST:%s, ERROR>>(%s)" % (hostname,result['msg'])
else:
return "HOST:%s, copy ok" % (hostname)
# 文件拉取到本地
def pull(self,pullsrcfile,savelocaldir):
pullfileres = ansible.runner.Runner(
host_list=self.hostlist,
remote_user=self.user,
remote_pass=self.passwd,
module_name='fetch',
module_args='src=%s dest=%s flat=yes' % (pullsrcfile, savelocaldir),
pattern=self.pattern,
forks=10
).run()
for (hostname,result) in pullfileres['contacted'].items():
if 'msg' in result:
return "HOST:%s ERROR>>(%s)" % (hostname,result['msg'])
else:
return 'HOST:%s pull ok' % (hostname)
if __name__ == "__main__":
pass
#*********三、urlib2调用http接口
#_*_coding:utf-8_*_
import urllib2
import json
#调用执行命令HTTP接口
def ansible_http_post_command(host,command):
url = 'http://192.168.89.8:5000/ansible/command'
data = {'host': host, 'command': command}
headers = {'Content-Type': 'application/json'}
req = urllib2.Request(url=url, headers=headers, data=json.dumps(data))
response = urllib2.urlopen(req)
return response.read()
#res = ansible_http_post_command('vm5',"uname -a")
#print res
#调用传送文件到目标主机的HTTP接口
def ansible_http_post_copyfile(srcfile,targethost,dectdir):
url = 'http://192.168.89.8:5000/ansible/copyfile'
data = {'srcfile': srcfile, 'targethost': targethost,'dectdir':dectdir}
headers = {'Content-Type': 'application/json'}
req = urllib2.Request(url=url, headers=headers, data=json.dumps(data))
response = urllib2.urlopen(req)
return response.read()
res = ansible_http_post_copyfile('/tmp/12345.txt','vm4','/root/')
print res
#调用从目标主机中拉取文件到本地的HTTP接口
def ansible_http_post_pullsend(srchost,pullsrcfile,savelocaldir):
url = 'http://192.168.89.8:5000/ansible/pullfile'
data = {'srchost':srchost,'pullsrcfile':pullsrcfile,'savelocaldir':savelocaldir}
headers = {'Content-Type': 'application/json'}
req = urllib2.Request(url=url, headers=headers, data=json.dumps(data))
response = urllib2.urlopen(req)
return response.read()
#res = ansible_http_post_pullsend('vm2','/tmp/12345.txt','/tmp/')
#print res另外有需要云服务器可以了解下创新互联scvps.cn，海内外云服务器15元起步，三天无理由+7*72小时售后在线，公司持有idc许可证，提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案，具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势，专为企业上云打造定制，能够满足用户丰富、多元化的应用场景需求。
本文名称：通过flask框架写成http接口调用Ansible-创新互联
本文URL：http://cqwzjz.cn/article/degsig.html
