因项目需要使用到ansible api，根据修改官方文档提供的使用范例，经过多次测试，现将能用的代码分享给大家，大家只需根据自己的实际环境修改该代码即可。

    官方文档：

    

    注意：

            在运行此代码的主机需无密码登录目标主机，也就是说您需要下发本机的ssh公钥到目标主机

    

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
#coding:utf-8
import 
json
from 
collections 
import 
namedtuple
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.plugins.callback 
import 
CallbackBase
 
class 
ResultCallback(CallbackBase):
    
def 
v2_runner_on_ok(
self
, result, 
*
*
kwargs):
        
host 
= 
result._host
        
print
(json.dumps({host.name: result._result}, indent
=
4
))
 
 
# 初始化需要的对象
Options 
= 
namedtuple(
'Options'
, [
'connection'
, 
'module_path'
, 
'forks'
, 
'become'
, 
'become_method'
, 
'become_user'
, 
'check'
, 
'diff'
])
 
# module_path参数指定本地ansible模块包的路径
loader 
= 
DataLoader()
options 
= 
Options(connection
=
'smart'
, module_path
=
'/usr/lib/python2.7/dist-packages/ansible/modules'
, forks
=
5
, become
=
None
, become_method
=
None
, become_user
=
"root"
, check
=
False
, diff
=
False
)
passwords 
= 
dict
(vault_pass
=
'secret'
)
 
# 实例化ResultCallback来处理结果
results_callback 
= 
ResultCallback()
 
# 创建库存(inventory)并传递给VariableManager
inventory 
= 
InventoryManager(loader
=
loader, sources
=
[
'../conf/hosts'
]) 
#../conf/hosts是定义hosts
variable_manager 
= 
VariableManager(loader
=
loader, inventory
=
inventory)
 
# 创建任务
play_source 
=  
dict
(
        
name 
= 
"Ansible Play"
,
        
hosts 
= 
"cephnode"
,
        
gather_facts 
= 
'no'
,
        
tasks 
= 
[
            
dict
(action
=
dict
(module
=
'shell'
, args
=
'touch /tmp/7.txt'
), register
=
'shell_out'
), 
#定义一条任务，如有多条任务也应按照这样的方式定义
         
]
    
)
play 
= 
Play().load(play_source, variable_manager
=
variable_manager, loader
=
loader)
 
# 开始执行
tqm 
= 
None
try
:
    
tqm 
= 
TaskQueueManager(
              
inventory
=
inventory,
              
variable_manager
=
variable_manager,
              
loader
=
loader,
              
options
=
options,
              
passwords
=
passwords,
              
stdout_callback
=
results_callback,  
# 使用自定义回调代替“default”回调插件（如不需要stdout_callback参数则按照默认的方式输出）
          
)
    
result 
= 
tqm.run(play)
finally
:
    
if 
tqm 
is 
not 
None
:
        
tqm.cleanup()

我的../conf/hosts文件内容如下：

[cephnode]

192.168.89.136

注意：

    如没有明确指定inventory（如下的参数），那么会默认从/etc/ansible/hosts中读取hosts

1
sources
=
[
'../conf/hosts'
]

    

补充一下，刚说了定义多条任务的方式，举个例子：

1
2
3
4
tasks 
= 
[
            
dict
(action
=
dict
(module
=
'shell'
, args
=
'mkdir /tmp/toby'
), register
=
'shell_out'
), 
#首先创建目录
            
dict
(action
=
dict
(module
=
'copy'
, args
=
'src=/tmp/abc123.txt dest=/tmp/toby'
), register
=
'shell_out'
) 
#然后将本地的abc123.txt通过copy模块下发到目标主机的/tmp/toby/目录下
         
]