1
2
3

[book]
title=hello
author=arvon

1
2

- name: print local fact
  debug: msg="Title is {{ ansible_local.example.book.title }}"

 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

###############################################################################
#Author: arvon
#Email: arvon2014@gmail.com
#Date: 2018/05/05
#Description: register etcd v3 and used by ansible lookup
#Notes:
###############################################################################
from ansible.plugins.lookup import LookupBase
import etcd3
import os
'''
Require and Document
pip install etcd3
V3-api: http://python-etcd3.readthedocs.io/en/latest/usage.html
'''
class Etcd_v3:
    def __init__(self, prefix, shardsinfo, ANSIBLE_ETCD_URL, type_module):
        self.prefix = prefix
        #self.version = version
        self.shardsinfo = shardsinfo
        self.etcd_url = ANSIBLE_ETCD_URL
        self.port = 2379
        self.type_module = type_module

    def gets(self):
        client = etcd3.client(host=self.etcd_url, port=self.port)
        client.get_prefix()
        return_dict = {}
        for shardid in self.shardsinfo:
            assign_dict = {}
            v3_prefix = os.path.join(self.prefix, str(self.shardsinfo[shardid]['gid']),self.type_module, str(shardid))
            #print v3_prefix
            gid = str(self.shardsinfo[shardid]['gid'])
            for v3_kv in client.get_prefix(v3_prefix, sort_order=None, sort_target='key'):
                #print v3_kv[1].key, v3_kv[0]
                assign_dict[v3_kv[1].key.split('/')[-1]] = v3_kv[0]
            default_prefix = os.path.join(self.prefix, gid, 'default')
            for default_kv in client.get_prefix(default_prefix, sort_order=None, sort_target='key'):
                #print default_kv[1].key,  default_kv[0]
                assign_dict[default_kv[1].key.split('/')[-1]] = default_kv[0]
            return_dict[shardid] =  assign_dict
        return return_dict
class LookupModule(LookupBase):
    def run(self, terms, variables, **kwargs):
        # validate_certs = kwargs.get('validate_certs', True)
        if len(terms) != 4:
            raise AnsibleError("parameter should be 4. prefix, dict of shardsinfo")
        etcd = Etcd_v3(terms[0], terms[1], terms[2], terms[3])
        return [etcd.gets()]
# Test command
if __name__ == '__main__':
    etcd = Etcd_v3('root_v3/wpys', {'15501':{'gid':155}},'10.17.1.32','gamex')
    a=etcd.gets()
    print (a)

1
2
3
4

- name: Get the contents of subnet mapping file and set it as a fact
  set_fact:
     get_etcd_special_keys:  "{{ lookup('get_etcdkeys_dict','{{ taiyouxi_etcd_prefix }}', '{{ansible_local.dev_gamex.shardsinfo}}', '{{ etcd_address }}', '{{ etcd_type }}') }}"

1
2
3

{% set hostip = ansible_eth0.ipv4.address %}  //set ip
{% set etcdvalue = item.value %}
DSN = {{etcdvalue.DSN}}

1
2
3

- name: copy chat.toml.j2 into /opt/supervisor/chat/conf
  template: src=confd/{{type}}/chat.toml.j2  dest="/opt/supervisor/chat/conf/chat.toml"
  with_dict: '{{get_etcd_special_keys}}'