通过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 '<h2>Access error</h2>'

@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 '<h2>Access error</h2>'

@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 '<h2>Access error</h2>'
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许可证，提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案，具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势，专为企业上云打造定制，能够满足用户丰富、多元化的应用场景需求。

成都创新互联专注为客户提供全方位的互联网综合服务，包含不限于成都网站制作、成都做网站、巩义网络推广、成都小程序开发、巩义网络营销、巩义企业策划、巩义品牌公关、搜索引擎seo、人物专访、企业宣传片、企业代运营等，从售前售中售后，我们都将竭诚为您服务，您的肯定，是我们大的嘉奖；成都创新互联为所有大学生创业者提供巩义建站搭建服务，24小时服务热线：18982081108，官方网址：www.cdcxhl.com

网页题目：通过flask框架写成http接口调用Ansible-创新互联
URL链接：https://www.cdcxhl.com/article6/degsig.html

成都网站建设公司_创新互联，为您提供小程序开发、网站策划、网站设计公司、企业建站、ChatGPT、App开发

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 创新互联