备案控制台
探索云世界
开发者社区 开发与运维 文章 正文

ansible2.4 api调用

2017-11-15 1437
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介：
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
75
76
77
78
79
80
81
82
83
84
85
86
87
AnsibleAPI.py 实现多进程发布代码
 
#!/usr/bin/python
# --*-- coding:utf-8 --*--
 
import  json
import  logging
from  ansible.parsing.dataloader  import  DataLoader
from  ansible. vars .manager  import  VariableManager
from  ansible.inventory.manager  import  InventoryManager
from  ansible.playbook.play  import  Play
from  ansible.executor.task_queue_manager  import  TaskQueueManager
from  ansible.executor.playbook_executor  import  PlaybookExecutor
from  ansible.plugins.callback  import  CallbackBase
from  collections  import  namedtuple
from  ansible  import  constants as C
import  ansible.executor.task_result
import  multiprocessing
 
 
class  ResultsCollector(CallbackBase):
     def  v2_runner_on_ok( self ,result):
         host  =  result._host
         logging.basicConfig(level = logging.DEBUG,
             format = '%(asctime)s %(filename)s[line:%(lineno)d] %(levelname)s %(message)s' ,
             datefmt = '%a, %d %b %Y %H:%M:%S' ,
             filename = '/root/cmdb/script/publish.log' ,
             filemode = 'w'
         )
         logging.warning( '===v2_runner_on_ok===host=%s===result=%s'  %  (host, result._result))
         #print(json.dumps({host.name: result._result}, indent=4))
         
     def  v2_runner_on_failed( self ,result,ignore_errors = False ):
         host  =  result._host
         logging.warning( '===v2_runner_on_failed====host=%s===result=%s'  %  (host, result._result))
 
     def  v2_runner_on_unreachable( self ,result):
         host  =  result._host
         logging.warning( '===v2_runner_on_unreachable====host=%s===result=%s'  %  (host, result._result))
 
 
 
class  AnsibleAPI( object ):
     def  __init__( self ,hostlist,image_name,playbooks,  * args,  * * kwargs):
         self .playbooks  =  playbooks
         self .passwords  =  None
         self .callback  =  None
         Options  =  namedtuple( 'Options' ,[ 'connection' , 'remote_user' , 'ask_sudo_pass' , 'verbosity' , 'ack_pass' , 'module_path' ,  'forks' ,  'become' ,  'become_method' , 'become_user' , 'check' ,  'listhosts' ,  'listtasks' ,  'listtags' , 'syntax' , 'sudo_user' ,  'sudo' ,  'diff' ])
         self .options  =  Options(connection = 'smart' ,remote_user = 'root' ,ack_pass = None ,sudo_user = 'root' ,forks = 5 , sudo = 'yes' , ask_sudo_pass = False , verbosity = 5 ,module_path = None ,become = True , become_method = 'sudo' , become_user = 'root' ,check = None , listhosts = False ,listtasks = False , listtags = None , syntax = None ,diff = False )
         self .loader  =  DataLoader()
         self .inventory  =  InventoryManager(loader = self .loader,sources = [ 'hosts' ])
         self .variable_manager  =  VariableManager(loader = self .loader,inventory = self .inventory)
         self .variable_manager.extra_vars  =  { "image_name" : image_name, 'host' :hostlist}
         
     def  runplaybook( self ):
         playbook  =  PlaybookExecutor(
             playbooks = self .playbooks,
             inventory = self .inventory,
             variable_manager = self .variable_manager,
             loader = self .loader,
             options = self .options,
             passwords = None )
         playbook._tqm._stdout_callback  =  ResultsCollector()
         
         playbook.run()
 
 
if  __name__  = =  '__main__' :
     # 创建对象
     an1  =  AnsibleAPI( '192.168.194.129,192.168.194.128' , 'common-oss-dc3a25.tar' ,[ '/etc/ansible/update.yml' ])
     #an2 = AnsibleAPI('192.168.194.128','common-oss-dc3a25.tar',['/etc/ansible/update.yml'])
     #processes = []
     p1  =  multiprocessing.Process(name = 'process_one' ,target = an1.runplaybook)
     #p2 = multiprocessing.Process(name='process_two',target=an1.runplaybook)
     #processes.append(p1)
     #processes.append(p2)
     #for p in processes:
     #   p.start()
 
     # 等待子进程结束，主进程退出
     #for p in processes:
     #   p.join()    #可以加浮点数参数，等待多久就不等了
     p1.start()
     if  p1.is_alive():
         print ( '正在发布' )
     else :
         print ( '发布结束' )
     本文转自小白的希望 51CTO博客，原文链接http://blog.51cto.com/haoyonghui/2052084：，如需转载请自行联系原作者




文章标签：
API
关键词：
API调用
技术小胖子
目录
相关文章
ftw2fzqaoykua
|
JSON 移动开发 Java
氚云丨开发课— 09平台 API 的调用及自定义 API 的编写与调用| 学习笔记
快速学习氚云丨开发课— 09平台 API 的调用及自定义 API 的编写与调用。
ftw2fzqaoykua
895 0
ybbf7fwncy2w2
|
API 开发工具 数据安全/隐私保护
如何调用 API | 学习笔记
简介：快速学习如何调用 API
ybbf7fwncy2w2
981 0
如何调用 API | 学习笔记
JAVA旭阳
|
前端开发 Java 程序员
如何在SpringBoot中优雅地重试调用第三方API？
如何在SpringBoot中优雅地重试调用第三方API？
JAVA旭阳
252 0
黄啊码
|
Java API
Java调用飞信API
Java调用飞信API
黄啊码
63 0
1124926287064587
|
Java 定位技术 API
java调用百度地图API根据地理位置获取经纬度
由于我们是使用百度提供的地理API接口，所以事先我们需要创建百度账号，并创建百度应用（因为我们要用应用到的ak）~~~~ 偷偷的告诉你们…这是免费的哦不要钱的…
1124926287064587
287 0
java调用百度地图API根据地理位置获取经纬度
yuanfan_2012
|
安全 Linux API
GrayLog使用HTTP JSONPath方式调用微步在线云API识别威胁IP
GrayLog使用HTTP JSONPath方式调用微步在线云API识别威胁IP
yuanfan_2012
317 0
GrayLog使用HTTP JSONPath方式调用微步在线云API识别威胁IP
刘鸿运
|
定位技术 API Python
python调用api接口不够
apifox
刘鸿运
122 0
python调用api接口不够
刘鸿运
|
数据采集 搜索推荐 API
我做的python 中文api调用模块
可以自动调用api接口
刘鸿运
229 1
一个风轻云淡
|
Java API Maven
java调用ZooKeeper API应用
java调用ZooKeeper API应用
一个风轻云淡
101 0
java调用ZooKeeper API应用
技术君
|
Java API
SAP Commerce Cloud 里的 Site API 调用方式讲解
Multiple Country Site Support 为管理包含多个内容目录并使用内容继承的站点提供原生支持。
技术君
92 0

热门文章

最新文章

  • 1
    Google Gemini API 接口调用方法
  • 2
    【C/C++ 数据库 sqlite3】SQLite C语言API返回值深入解析
  • 3
    免费使用Kimi的API接口，kimi-free-api真香
  • 4
    Java 学习路线：基础知识、数据类型、条件语句、函数、循环、异常处理、数据结构、面向对象编程、包、文件和 API
  • 5
    产品经理必备知识——API接口
  • 6
    实战篇：商品API接口在跨平台销售中的有效运用与案例解析
  • 7
    探究如何在Linux系统中修改进程资源限制:四种方法调整进程限制，让你的系统高效运行(包含应用层getrlimit和setrlimit API)
  • 8
    阿里云微服务引擎及 API 网关 2024 年 3 月产品动态
  • 9
    利用Django框架构建高效后端API服务
  • 10
    Serverless 应用引擎常见问题之API生成的函数镜像改为自定义的镜像如何解决
  • 1
    常用JavaScript 数组 API大全
    32
  • 2
    JavaScript循环遍历常用的7种方法以及常用的数组 API
    34
  • 3
    解释如何在 Python 中实现 Web 服务（RESTful API）。
    25
  • 4
    Java 8新特性之Lambda表达式和Stream API
    21
  • 5
    视觉智能平台常见问题之抠人脸的api如何解决
    29
  • 6
    API安全中的数据隐私保护步骤
    30
  • 7
    亚马逊API接口获取商品详情的全面指南
    43
  • 8
    从API到Agent：万字长文洞悉LangChain工程化设计
    91
  • 9
    如何在Linux使用docker部署Swagger Editor并实现无公网IP远程协同编辑API文档
    47
  • 10
    虾皮Shopee根据ID取商品详情API
    28

    • 相关课程

    更多
  • 体验-K8S API 基础及Pod 基本应用

    • 相关电子书

    更多
  • CUDA MATH API
  • API PLAYBOOK
  • 传统企业的“+互联网”-API服务在京东方的实践

    • 相关实验场景

    更多
  • 快速体验智能体API应用
  • Elasticsearch Java API Client 开发
    • 下一篇
    阿里云oss简介和使用流程