dynamic inventory

ansible에서는 인벤토리를 디비나 api등에서 받아올수 있는 기능을 지원합니다.

architecture

inventory plugin

ansible-doc -t inventory -l

인벤토리 플러그인 리스트를 보실수 있습니다.

여기서 우리는 스크립트 플러그인을 사용할 것입니다.

스펙

어떤 스크립트든 실행만 가능하고 json으로 inventory를 출력하면 됩니다. (php, python, ruby, bash, perl, go, powershell, etc)

저는 go를 사용하여 만들어 보았습니다.

기존에 있던 cli에 위 기능만 추가하여 만들었습니다. https://teamsmiley.gitbook.io/devops/go-lang/create-cli

cli 옵션 추가

rootCmd.PersistentFlags().BoolVarP(&list, "list", "l", false, "ansible inventory --list")
rootCmd.PersistentFlags().StringVar(&name, "host", "", "ansible inventory --host")

binary에서 두개의 옵션을 지원을 하여야 합니다. --list와 --host입니다.

--list는 인벤토리를 출력하고 --host는 특정 호스트의 정보를 출력합니다.

var rootCmd = &cobra.Command{
	Use:   "myctl",
	Short: "myctl",
	// Uncomment the following line if your bare application
	// has an action associated with it:
	Run: func(cmd *cobra.Command, args []string) {
		server.GetAnsible(name)
	},
}

이제 프로그램이 실행되면 server.GetAnsible(name)를 실행합니다.

restapi를 호출하여 json을 받아오면 됩니다.

func GetAnsible(hostname string) {
	oauthTokenProvider := new(tokenProvider)

	t := oauthTokenProvider.OAuthToken()
	// fmt.Println("hostname", hostname)

	result := httpApi.GetAnsible(hostname, t)

	fmt.Print(result)

}

func GetAnsible(hostname string, oauthToken string) string {
	getInventory := "https://api.cmdb.aaa.com/inventories"

	r, err := http.NewRequest(http.MethodGet, getInventory, nil)
	if err != nil {
		panic(err)
	}

	r.Header.Add("Content-Type", "application/json")

	// appending to existing query args
	q := r.URL.Query()
	if hostname != "" {
		q.Add("name", hostname)
	}

	// assign encoded query string to http request
	r.URL.RawQuery = q.Encode()

	resp, err := http.DefaultClient.Do(r)

	if err != nil {
		panic(err)
	}

	defer resp.Body.Close()

	responseBody, err := ioutil.ReadAll(resp.Body)

	if err != nil {
		panic(err)
	}

	return string(responseBody)
}

이제 cli는 준비가 됬으니 rest api를 통해서 디비에서 가져와보자.

rest api (c#)

// --list의 경우
var query = _context.Servers
                            .Where(x => x.DeletedFlag == false)
                            .Where(x => x.StatusValue == (int)EnumStatus.Active)
                            .ApplySort(request.OrderBy, _propertyMappingService.GetPropertyMapping<GetInventoriesQuery, Server>())
                            .AsQueryable()
                            ;

// --host일경우 hostname하나만 가져온다.
if (request.Name != null)
{
    query = query.Where(x => x.Name == request.Name);
}

// az로 그룹핑을 해봣다.
var entities = query.GroupBy(x => new { x.SiteId, x.ServerType },
                        (key, group) => new Inventory
                        {
                            AZ = key.SiteId == (int)EnumSite.SV4 ? "sv4"
                                        : key.SiteId == (int)EnumSite.SV5 ? "sv5"
                                        : key.SiteId == (int)EnumSite.DC3 ? "dc3"
                                        : "Unknown",
                            ServerType = key.ServerType == (int)EnumServerType.BAREMETAL ? "baremetal"
                                        : key.ServerType == (int)EnumServerType.VM ? "vm"
                                        : "Unknown",
                            Hosts = group.Select(x => x.Name).Take(10).ToList()
                        })
                    .ToList()
                    ;

//여기서부터는 json으로 만들어준다.

var json = new StringBuilder();
json.Append("{\"_meta\": {\"hostvars\":{}},"); // - 1 중요

var allGroup = new StringBuilder();
allGroup.Append("\"all\": {\"children\": [");

var allHosts = new StringBuilder();

foreach (var item in entities)
{
    allHosts.Append("\"" + item.AZ + "-" + item.ServerType + "\",");
}

json.Append(allGroup.ToString());

json.Append(allHosts.ToString().Substring(0, allHosts.ToString().Length - 1));

json.Append("]},");

var hostsByGroup = new StringBuilder();

foreach (var item in entities)
{
    hostsByGroup.Append("\"" + item.AZ + "-" + item.ServerType + "\": {\"hosts\": [");

    var hosts = new StringBuilder();

    foreach (var host in item.Hosts)
    {
        hosts.Append("\"" + host + "\",");
    }

    hostsByGroup.Append(hosts.ToString().Substring(0, hosts.ToString().Length - 1));
    hostsByGroup.Append("]},");
}
json.Append(hostsByGroup.ToString().Substring(0, hostsByGroup.ToString().Length - 1));
json.Append("}");

return json.ToString();