Ansible playbook API 開發 調用測試

    Ansible是Agentless的輕量級批量配置管理工具，由於出現的比較晚（13年）基於Ansible進行開發的相關文檔較少，因此，這里通過一些小的實驗，結合現有資料以及源碼，探索一下Ansible的二次開發。

    隨筆的內容分為三個部分

1. playbook編輯執行
2. python 調用API執行playbook
3. java調用python程序進行playbook的執行

    實驗的環境是centos6，ansible版本是1.9.4，python版本是2.6.6，jdk版本是1.7U79

 

一、playbook編輯執行

　　編輯playbook，這里實現的功能是復制一個腳本到指定節點並執行，需要注意的是yaml的格式,注意縮進

　　webAuth.yml

---

- name: hostname

  hosts: "{{host}}"

  sudo: yes

  tasks:

    - name: copy file to "{{host}}"

      copy: src=/tmp/webAuth.sh dest=/tmp/webAuth.sh mode=0775

   

    - name: execute webAuth

      script: /tmp/webAuth.sh

 

 

　　如果想運行該playbook可以使用

# ansible-playbook /opt/ansible/webAuth.yml --extra-vars 'host=’nodes'

 

　　此時將會有返回結果。

PLAY [hostname] ***************************************************************

 

GATHERING FACTS ***************************************************************

ok: [192.168.10.110]

 

TASK: [copy file to "{{host}}"] ***********************************************

ok: [192.168.10.110]

 

TASK: [execute webAuth] *******************************************************

changed: [192.168.10.110]

 

PLAY RECAP ********************************************************************

192.168.10.110              : ok=3    changed=1    unreachable=0    failed=0

　　 能夠執行成功說明playbook是沒問題的，如果報錯誤，那么根據提示進行修改即可。

二、python 調用API執行playbook

　　　　下面使用Python調用API接口執行上面的playbook

Python代碼： test.py
import sys
import ansible.playbook
from ansible import callbacks
from ansible import utils

stats = callbacks.AggregateStats()
playbook_cb = callbacks.PlaybookCallbacks(verbose=utils.VERBOSITY)
runner_cb = callbacks.PlaybookRunnerCallbacks(stats, verbose=utils.VERBOSITY)
def execute(play,params):
  pb = ansible.playbook.PlayBook(
    playbook=play,
    stats=stats,
    callbacks=playbook_cb,
    runner_callbacks=runner_cb,
    check=False,
    extra_vars=eval(params)
  )
  print pb
  return  pb.run()
if __name__=='__main__':
  res=execute(sys.argv[1],sys.argv[2])
  print res

 

代碼中 playbook=play 是由命令行給出需要執行的playbook腳本路徑，stats是用於收集執行的過程狀態，playbook_cb是playbook_cb 用來輸出執行的結果，runner_callbacks用來輸出playbook執行期間的結果。

執行

python test.py /opt/ansible/webAuth.yml '{"host":"cloudeploy-nodes"}'

 

返回結果：

PLAY [hostname] ***************************************************************

 

GATHERING FACTS ***************************************************************

ok: [192.168.10.110]

 

TASK: [copy file to "{{host}}"] ***********************************************

changed: [192.168.10.110]

 

TASK: [execute webAuth] *******************************************************

ok: [192.168.10.110]

{'192.168.10.110': {'unreachable': 0, 'skipped': 0, 'ok': 2, 'changed': 1, 'failures': 0}}

 

 

 

三、java調用python程序進行playbook的執行

　　使用JAVA調用python來實現java執行playbook

Test.java

import java.io.InputStreamReader;

import java.io.BufferedReader;

import java.io.InputStream;

import java.io.IOException;

public class Test{

  public static void main(String args[]) throws IOException{

    String command="python /opt/ansible/test.py /opt/ansible/hostname.yml {'host':'"+args[0]+"'}";

    Process process = Runtime.getRuntime().exec(command);

    printStream(process.getInputStream());

    printStream(process.getErrorStream());

    System.out.println("finish");

  }

private static void printStream(InputStream inputStream) {

  if (inputStream == null){

    System.out.println("input null");

    return;

  }

  String line = "";

    try(BufferedReader input = new BufferedReader(new InputStreamReader(inputStream)))

    {

      while ((line = input.readLine()) != null) {

        System.out.println(line);

      }

    } catch (IOException e1) {

        System.out.println("輸出流失敗"+e1);

        e1.printStackTrace();

    }

  }

}

 

 

調用

#java Test cloudeploy

這里將playbook的路徑固定了，同樣可以作為參數傳入。

執行結果：

PLAY [hostname] *************************************************************** 

GATHERING FACTS *************************************************************** 
ok: [192.168.10.110]

TASK: [return hostname] ******************************************************* 
changed: [192.168.10.110]

TASK: [copy file to "{{host}}"] *********************************************** 
ok: [192.168.10.110]

TASK: [execute webAuth] ******************************************************* 
changed: [192.168.10.110]
{'192.168.10.110': {'unreachable': 0, 'skipped': 0, 'ok': 4, 'changed': 2, 'failures': 0}}
finish

表明執行成功，查看對應節點，文件將被復制並執行

 

參考資料：

Github： playbook 源碼 ：https://github.com/ansible/ansible/blob/release1.8.4/lib/ansible/playbook/__init__.py

Kisips： Ansible文檔 playbook進階： http://www.kisops.com/?p=42

361way： ansible小節十 ansible api  http://www.361way.com/ansible-api/4446.html

StackOverflow ：Running ansible-playbook using Python API   http://stackoverflow.com/questions/27590039/running-ansible-playbook-using-python-api

Ansible ：developing api http://docs.ansible.com/ansible/developing_api.html

google： ansible 論壇   https://groups.google.com/forum/#!topic/ansible-project/V1PoNJcXV_w