ansible笔记

目录

列表的使用
zookeeper id 使用主机名最后的编号
判断一个文件是否是默认的，如果是就清空
blockinfile+lookup使用
replace+lookup使用
ansible2.4 api 调用

列表的使用

我们有一个列表如下（主机为server7-13）

(py3) [root@jumpserver app]# cat server_elk.yml
- hosts:  ~server[7-9]$:~server1[0-3]$
  vars:
    topics_list:
      - test
      - test1
    cluster_list:
      - server7
      - server8
      - server9
      - server10
      - server11
      - server12
      - server13
  roles:
   # - common
    - elk

如我们需要用logstash往es里面写,下面是我们需要的效果

input {
  kafka {
    bootstrap_servers => "server7:9096,server8:9096,server9:9096,server10:9096,server11:9096,server12:9096,server13:9096"
    topics => ["test","test1"]
  }
}
filter {
  json {
    source => "message"
  }
  mutate {
  convert => { "upstream_response_time" => "float" }
  convert => { "request_time" => "float" }
  convert => { "status" => "integer" }
  remove_field => "message"
  }
  geoip {
      source => "remote_addr"
      add_field => [ "[geoip][coordinates]", "%{[geoip][longitude]}" ]
      add_field => [ "[geoip][coordinates]", "%{[geoip][latitude]}"  ]
  }
  mutate {
    convert => [ "[geoip][coordinates]", "float"]
  }
}

output {
  elasticsearch {
    hosts => ["server7:9200","server8:9200","server9:9200","server10:9200","server11:9200","server12:9200","server13:9200"]
    index => "logstash-%{[type]}-%{+YYYY.MM.dd}"
  }
}

ansible的template可以这样写

input {
  kafka {
    bootstrap_servers => "{{ cluster_list|map('regex_replace', '^(.*)$', '\1:9096')|join(',') }}"
    topics => [{{ topics_list|map('regex_replace', '^(.*)$', '"\1"')|join(',') }}]
  }
}
filter {
  json {
    source => "message"
  }
  mutate {
  convert => { "upstream_response_time" => "float" }
  convert => { "request_time" => "float" }
  convert => { "status" => "integer" }
  remove_field => "message"
  }
  geoip {
      source => "remote_addr"
      add_field => [ "[geoip][coordinates]", "%{[geoip][longitude]}" ]
      add_field => [ "[geoip][coordinates]", "%{[geoip][latitude]}"  ]
  }
  mutate {
    convert => [ "[geoip][coordinates]", "float"]
  }
}

output {
  elasticsearch {
    hosts => [{{ cluster_list|map('regex_replace', '^(.*)$', '"\1:9200"')|join(',') }}]
    index => "logstash-%{[type]}-%{+YYYY.MM.dd}"
  }
}

zookeeper id 使用主机名最后的编号

如server7的myid就是7

[root@server11 ~]# cat /opt/zookeeper/data/myid
11

template 中需要

# cat  roles/common/templates/myid.j2
{{ ansible_hostname|replace('-','/') |basename}}

判断一个文件是否是默认的，如果是就清空

比如我们安装filebeat，然后/etc/filebeat/filebeat.yml这个文件是默认的话，我们就需要清空，不是我们需要用blockinfile往里面填东西，由于有多次添加的需要，而且还需要做成状态的所以有了这个需求

- name: reset file config is the /etc/filebeat/filebeat.yml file is default
  shell: "[[ $(md5sum /etc/filebeat/filebeat.yml) == 582eb1601bde332db2d09d2ee2d8286b* ]] && > /etc/filebeat/filebeat.yml"
  ignore_errors: True

blockinfile + lookup 使用

lookup 可以lookup很多东西如dns，file等等具体可以看(官方文档)[http://docs.ansible.com/ansible/latest/playbooks_lookups.html]

- name: copy filebeat header config
  blockinfile:
    path: /etc/filebeat/filebeat.yml
    block: "{{ lookup('template', 'header.yml') }}"
    marker: "# {mark} filebeat header"
    insertbefore: BOF
  notify:
    - restart filebeat


- name: copy filebeat.prospectors config
  blockinfile:
    path: /etc/filebeat/filebeat.yml
    block: "{{ lookup('template', 'input_type.yml') }}"
    marker: "# {mark} filebeat {{ document_type }}"
    insertafter: "# END filebeat header"
  notify:
    - restart filebeat

- name: copy filebeat output config
  blockinfile:
    path: /etc/filebeat/filebeat.yml
    block: "{{ lookup('template', 'output.yml') }}"
    marker: "# {mark} filebeat output"
    insertafter: EOF
  notify:
    - restart filebeat

replace + lookup 使用

这个file文件就放在roles/nginx_conf/files下面

- name: add access_log_json
  blockinfile:
    path: "{{ nginx_file }}"
    marker: "# {mark} access_log_json "
    insertafter: 'http_x_forwarded_for"'
    content: "{{ lookup('file', './access_log_json') }}"
    backup: yes
  notify:
    - reload nginx

- name: change file to access_log_json
  replace:
    path: "{{ nginx_file }}"
    regexp: 'access_log  {{ logfile }} main;'
    replace: 'access_log  {{ logfile }} access_log_json;'
    backup: yes
  notify:
    - reload nginx

# cat roles/nginx_conf/files/access_log_json
    log_format  access_log_json      '{"remote_addr":"$remote_addr","host":"$host","time_iso8601":"$time_iso8601","request":"$request","status":"$status","body_bytes_sent":"$body_bytes_sent","http_referer":"$http_referer","http_user_agent":"$http_user_agent","http_x_forwarded_for":"$http_x_forwarded_for","upstream_response_time":"$upstream_response_time","uri":"$uri","request_time":"$request_time"}'

ansible2.4 api 调用

需要更改的地方就是inventory的地方,sources改成自己inventory文件的位置，然后hosts配置成自己需要操作的主机名就行了，这里面好多参数其实都可以ansible --help来看，一下是根据官网的例子改写的，不过就简单的能跑shell模块了。

#!/usr/bin/env python

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):
    """A sample callback plugin used for performing an action as results come in

    If you want to collect all results into a single object for processing at
    the end of the execution, look into utilizing the ``json`` callback plugin
    or writing your own custom callback plugin
    """
    def v2_runner_on_failed(self, result, **kwargs):
        print(result._host)

    def v2_runner_on_unreachable(self, result):
        print("*"*10, "v2_runner_on_unreachable")
        print(result._host)

    def v2_runner_on_ok(self, result, **kwargs):
        """Print a json representation of the result

        This method could store the result in an instance attribute for retrieval later
        """
        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'])
# initialize needed objects
loader = DataLoader()
options = Options(connection='smart', module_path='/path/to/mymodules', forks=100, become=None, become_method=None, become_user=None, check=False,
                  diff=False)
passwords = dict(vault_pass='secret')

# Instantiate our ResultCallback for handling results as they come in
results_callback = ResultCallback()

# create inventory and pass to var manager
#inventory = InventoryManager(loader=loader, sources=['localhost'])
inventory = InventoryManager(loader=loader, sources=['/etc/ansible/d_inv.py'])
variable_manager = VariableManager(loader=loader, inventory=inventory)

# create play with tasks
play_source =  dict(
        name = "Ansible Play",
        hosts = 'node1.com',
        gather_facts = 'no',
        tasks = [
            #dict(action=dict(module='shell', args='ls'), register='shell_out'),
            dict(action=dict(module='shell', args='route -n'), ),
            #dict(action=dict(module='debug', args=dict(msg='{{shell_out.stdout}}')))
         ]
    )
play = Play().load(play_source, variable_manager=variable_manager, loader=loader)

# actually run it
tqm = None
try:
    tqm = TaskQueueManager(
              inventory=inventory,
              variable_manager=variable_manager,
              loader=loader,
              options=options,
              passwords=passwords,
              stdout_callback=results_callback,  # Use our custom callback instead of the ``default`` callback plugin
          )
    result = tqm.run(play)
finally:
    if tqm is not None:
        tqm.cleanup()